From 30be0df31405473bc28b50dc1397c10b780a4ec3 Mon Sep 17 00:00:00 2001 From: Igor Ilic Date: Thu, 10 Jul 2025 23:49:00 +0200 Subject: [PATCH] fix: Resolve for loop break issue --- cognee/modules/pipelines/operations/run_tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cognee/modules/pipelines/operations/run_tasks.py b/cognee/modules/pipelines/operations/run_tasks.py index 549f233aa..b0e2d432d 100644 --- 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(