fix: Resolve for loop break issue

2025-07-10 23:49:00 +02:00 · 2025-07-10 23:49:00 +02:00 · 30be0df314
commit 30be0df314
parent dc38ff3838
1 changed files with 1 additions and 1 deletions
--- a/cognee/modules/pipelines/operations/run_tasks.py
+++ b/cognee/modules/pipelines/operations/run_tasks.py
@ -119,7 +119,7 @@ async def run_tasks(
                        ).scalar_one_or_none()
                        if data_point:
                            if data_point.pipeline_status.get(pipeline_name) == "Completed":
-                                break
+                                continue

            try:
                async for result in run_tasks_with_telemetry(