-
Notifications
You must be signed in to change notification settings - Fork 1.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Remove asset key iteration from backfill daemon, part 2 #26727
base: bfsreal
Are you sure you want to change the base?
Conversation
refactor > Insert changelog entry or delete this section. moar refactor > Insert changelog entry or delete this section. subsets instead of values > Insert changelog entry or delete this section. more progress on subsets instead of values > Insert changelog entry or delete this section. more progress > Insert changelog entry or delete this section. yet more progress > Insert changelog entry or delete this section. more progress > Insert changelog entry or delete this section. more > Insert changelog entry or delete this section. renames > Insert changelog entry or delete this section. final names? > Insert changelog entry or delete this section.
> Insert changelog entry or delete this section.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This looks great, excited for this. Added a few renames for your consideration
) -> "AssetBackfillData": | ||
requested_partitions = get_requested_asset_partitions_from_run_requests( | ||
requested_partitions = _get_requested_asset_graph_subset_from_run_requests( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: rename requested_partitions
to requested_subset
@@ -1467,16 +1440,16 @@ def execute_asset_backfill_iteration_inner( | |||
RemoteWorkspaceAssetGraph, asset_graph_view.asset_graph | |||
) | |||
|
|||
initial_candidates: Set[AssetKeyPartitionKey] = set() | |||
initial_asset_graph_subset: AssetGraphSubset = AssetGraphSubset.empty() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
consider naming this candidate_asset_graph_subset
?
> Insert changelog entry or delete this section.
b93ead9
to
41e786b
Compare
b7b5a2e
to
43b9cdd
Compare
Summary & Motivation
Clears out the other places in the asset backfill daemon where we were iterating through AssetKeyPartitionKeys, in favor of using AssetGraphSubsets.
How I Tested These Changes
BK
Changelog
NOCHANGELOG