fix(retrieval): waiting flow would time out

phwissmann · phwissmann · commit 463c47da558c · 2025-11-21T12:05:43.000+01:00
Should wait forever for the other flow
diff --git a/backend/archiver/flows/retrieve_datasets_flow.py b/backend/archiver/flows/retrieve_datasets_flow.py
@@ -193,7 +193,7 @@ def find_oldest_dataset_flow(
     on_failure=[on_job_flow_failure],
 )
 async def wait_for_retrieval_flow(flow_run_id: uuid.UUID):
-    flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True)
+    flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True, timeout=None, poll_interval=60)
     flow_run.state.result()
 
 

Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,7 @@ def find_oldest_dataset_flow(`
`193`	`193`	`on_failure=[on_job_flow_failure],`
`194`	`194`	`)`
`195`	`195`	`async def wait_for_retrieval_flow(flow_run_id: uuid.UUID):`
`196`		`- flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True)`
	`196`	`+ flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True, timeout=None, poll_interval=60)`
`197`	`197`	`flow_run.state.result()`
`198`	`198`
`199`	`199`