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 d2bcc2a6fdc10..a2dd9d1643858 100644 --- a/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py +++ b/python_modules/dagster/dagster/_core/definitions/asset_graph_subset.py @@ -244,12 +244,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 282be7ac69a9d..6fdaa6e19afba 100644 --- a/python_modules/dagster/dagster/_core/execution/asset_backfill.py +++ b/python_modules/dagster/dagster/_core/execution/asset_backfill.py @@ -1279,7 +1279,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, @@ -1289,8 +1289,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"), )