Chris Dong
11/09/2022, 5:38 PMyuhan
11/09/2022, 9:51 PMfrom dagster import DagsterInstance, RunsFilter, DagsterRun
with DagsterInstance.get() as instance:
while True:
runs = instance.get_runs(
RunsFilter(tags=DagsterRun.tags_for_backfill_id(<insert your backfill id>)),
limit=25
)
if not runs:
break
for run in runs:
instance.delete_run(run.run_id)