diff --git a/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py b/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py index feac626707292..dd184e4c42b0b 100644 --- a/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py +++ b/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py @@ -242,12 +242,6 @@ def __repr__(self) -> str: ")" ) - @classmethod - def empty(cls): - return AssetGraphSubset( - partitions_subsets_by_asset_key={}, non_partitioned_asset_keys=set() - ) - @classmethod def from_asset_partition_set( cls, diff --git a/python_modules/dagster/dagster/_core/execution/asset_backfill.py b/python_modules/dagster/dagster/_core/execution/asset_backfill.py index e20fa66a3d0bd..28f1f53f4a7a8 100644 --- a/python_modules/dagster/dagster/_core/execution/asset_backfill.py +++ b/python_modules/dagster/dagster/_core/execution/asset_backfill.py @@ -1290,7 +1290,7 @@ def get_canceling_asset_backfill_iteration_data( instance_queryer, backfill_id, asset_graph, - materialized_subset=AssetGraphSubset.empty(), + materialized_subset=updated_materialized_subset, ) ), asset_graph, @@ -1300,8 +1300,7 @@ def get_canceling_asset_backfill_iteration_data( latest_storage_id=asset_backfill_data.latest_storage_id, requested_runs_for_target_roots=asset_backfill_data.requested_runs_for_target_roots, materialized_subset=updated_materialized_subset, - failed_and_downstream_subset=asset_backfill_data.failed_and_downstream_subset - | failed_subset, + failed_and_downstream_subset=failed_subset, requested_subset=asset_backfill_data.requested_subset, backfill_start_time=TimestampWithTimezone(backfill_start_timestamp, "UTC"), )