Valentine Kim
08/24/2022, 12:08 PMchris
08/25/2022, 12:07 AMfrom dagster import DagsterInstance, DagsterRunStatus
instance = DagsterInstance.get()
for run in instance.get_runs():
if run.status == DagsterRunStatus.QUEUED:
instance.delete_run(run.run_id)
Roel Hogervorst
09/01/2022, 2:41 PMRoel Hogervorst
09/01/2022, 2:42 PMValentine Kim
09/01/2022, 2:52 PM