Skip to content

Commit

Permalink
small cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Sep 7, 2023
1 parent c15b326 commit 181ff5d
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -934,7 +934,6 @@ def _fetch_input_asset_version_info(self, key: AssetKey) -> None:
# Input name will be none if this is an internal dep
input_name = self.job_def.asset_layer.input_for_asset_key(self.node_handle, key)
# Exclude AllPartitionMapping for now to avoid huge queries
# TODO - need to solve the self dependent partition issue with the method refactors
if input_name and self.has_asset_partitions_for_input(input_name):
subset = self.partitions_subset_for_upstream_asset(
key, require_valid_partitions=False
Expand Down Expand Up @@ -1020,8 +1019,6 @@ def get_output_asset_keys(self) -> AbstractSet[AssetKey]:
output_keys.add(asset_info.key)
return output_keys

#### Partitions methods

def has_asset_partitions_for_input(self, input_name: str) -> bool:
asset_layer = self.job_def.asset_layer
upstream_asset_key = asset_layer.asset_key_for_input(self.node_handle, input_name)
Expand Down

0 comments on commit 181ff5d

Please sign in to comment.