workflow use queue now

Querent-ai · Apr 17, 2024 · 9da2a19 · 9da2a19
1 parent 88645d4
commit 9da2a19
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/querent/ingestors/ingestor_manager.py b/querent/ingestors/ingestor_manager.py
@@ -158,7 +158,7 @@ async def chunk_generator() -> AsyncGenerator[CollectedBytes, None]:
 
                 async for chunk_tokens in ingestor.ingest(chunk_generator()):
                     if self.result_queue is not None:
-                        await self.result_queue.put_nowait(chunk_tokens)
+                        self.result_queue.put_nowait(chunk_tokens)
                     # elif tokens_feader is not None:
                     #     tokens_feader.send_tokens_in_rust(
                     #         {