Skip to content

Commit

Permalink
filter run_ids before calling get_runs (dagster-io#24873)
Browse files Browse the repository at this point in the history
filter out runless events '' run_id
  • Loading branch information
alangenfeld authored Sep 28, 2024
1 parent 574df1c commit c617f66
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -296,6 +296,7 @@ def passes(
run_ids_to_fetch = list(asset_partitions_by_latest_run_id.keys())
for i in range(0, len(run_ids_to_fetch), run_step):
run_ids = run_ids_to_fetch[i : i + run_step]
run_ids = [run_id for run_id in run_ids if run_id]
runs = context.legacy_context.instance_queryer.instance.get_runs(
filters=RunsFilter(run_ids=run_ids)
)
Expand Down

0 comments on commit c617f66

Please sign in to comment.