Dan Wise
11/11/2022, 5:23 PMAaron
11/11/2022, 5:42 PMDan Wise
11/11/2022, 6:47 PMAaron
11/11/2022, 6:49 PMNate
11/11/2022, 8:59 PMfrom prefect.client import get_client()
async with get_client() as client:
try:
runs = await client.get_runs_in_work_queue("<MY-QUEUE-UUID>")
for run in runs:
await client.delete_flow_run(flow_run_id=run.id)
Dan Wise
11/12/2022, 8:51 AM