Skip to content
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

Open
wants to merge 5 commits into
base: bfsreal
Choose a base branch
from

Conversation

gibsondan
Copy link
Member

@gibsondan gibsondan commented Dec 26, 2024

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

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.
> Insert changelog entry or delete this section.
Copy link
Contributor

@clairelin135 clairelin135 left a 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(
Copy link
Contributor

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()
Copy link
Contributor

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.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants