Vadym Dytyniak
03/17/2022, 11:37 AMAnna Geller
03/17/2022, 11:49 AMwait_for_flow_run(task_args=dict(timeout=3600))
# 2 Not directly, but you can retrieve the flow run ID from the prefect context and use it to cancel the flow run. Also: you can't cancel flows, only flow runs, and for that, you need the flow run ID
Can you describe your use case more?Vadym Dytyniak
03/17/2022, 12:38 PMAnna Geller
03/17/2022, 12:55 PMVadym Dytyniak
03/17/2022, 12:59 PMKevin Kho
03/17/2022, 1:54 PMwait_for_flow_run.timeout = ...
Vadym Dytyniak
03/17/2022, 2:03 PMKevin Kho
03/17/2022, 2:28 PMVadym Dytyniak
03/17/2022, 2:30 PMKevin Kho
03/17/2022, 2:30 PMVadym Dytyniak
03/17/2022, 2:30 PMquery {
flow_run(where:
{
name: { _like: "pattern.%" },
state: { _eq: "Submitted"}
}
) {
id,
name,
state,
created
}
}
Kevin Kho
03/17/2022, 2:31 PMVadym Dytyniak
03/17/2022, 2:31 PMKevin Kho
03/17/2022, 2:40 PM