Skip to content

Commit d2f9408

Browse files
authored
Fix timeout when waiting for flow (#301)
2 parents b27be37 + 51629d4 commit d2f9408

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

backend/archiver/flows/retrieve_datasets_flow.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -189,11 +189,10 @@ def find_oldest_dataset_flow(
189189

190190
@flow(
191191
name="wait_for_retrieval_flow",
192-
log_prints=True,
193-
on_failure=[on_job_flow_failure],
192+
log_prints=True
194193
)
195194
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)
195+
flow_run: FlowRun = await wait_for_flow_run(flow_run_id, log_states=True, timeout=None, poll_interval=60)
197196
flow_run.state.result()
198197

199198

0 commit comments

Comments
 (0)