Skip to content

Commit 6f4181b

Browse files
committed
🐛 (tasks) Fix ingest_path emitted store as well
1 parent 59d8340 commit 6f4181b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

ingestors/tasks.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,5 +77,6 @@ def ingest_path(
7777
manager.queue_entity(entity)
7878
if path.is_dir():
7979
DirectoryIngestor.crawl(manager, path)
80-
log.info(f"Emitted {len(manager.emitted)} entities.", emitted=manager.emitted)
80+
emitted = list(manager.emitted.iterate())
81+
log.info(f"Emitted {len(emitted)} entities.", emitted=[e.id for e in emitted])
8182
manager.close()

0 commit comments

Comments
 (0)