fix(retrieval): Don't run failure hook in waiting flow

phwissmann · phwissmann · commit 51629d4e9250 · 2025-11-21T12:05:43.000+01:00
The parent flow will call the error hook
diff --git a/backend/archiver/flows/retrieve_datasets_flow.py b/backend/archiver/flows/retrieve_datasets_flow.py
@@ -189,8 +189,7 @@ def find_oldest_dataset_flow(
 
 @flow(
     name="wait_for_retrieval_flow",
-    log_prints=True,
-    on_failure=[on_job_flow_failure],
+    log_prints=True
 )
 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, timeout=None, poll_interval=60)

Original file line number	Diff line number	Diff line change
`@@ -189,8 +189,7 @@ def find_oldest_dataset_flow(`
`189`	`189`
`190`	`190`	`@flow(`
`191`	`191`	`name="wait_for_retrieval_flow",`
`192`		`- log_prints=True,`
`193`		`- on_failure=[on_job_flow_failure],`
	`192`	`+ log_prints=True`
`194`	`193`	`)`
`195`	`194`	`async def wait_for_retrieval_flow(flow_run_id: uuid.UUID):`
`196`	`195`	`flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True, timeout=None, poll_interval=60)`