Skip to content

Commit

Permalink
Union[OpDefinition, GraphDefinition] -> NodeDefinition in type annota… (
Browse files Browse the repository at this point in the history
#21561)

…tions

## Summary & Motivation

## How I Tested These Changes
  • Loading branch information
sryza authored May 1, 2024
1 parent e4325de commit c943a90
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions python_modules/dagster/dagster/_core/definitions/assets.py
Original file line number Diff line number Diff line change
Expand Up @@ -642,7 +642,7 @@ def from_op(

@staticmethod
def _from_node(
node_def: Union[OpDefinition, "GraphDefinition"],
node_def: NodeDefinition,
*,
keys_by_input_name: Optional[Mapping[str, AssetKey]] = None,
keys_by_output_name: Optional[Mapping[str, AssetKey]] = None,
Expand Down Expand Up @@ -1587,7 +1587,7 @@ def get_attributes_dict(self) -> Dict[str, Any]:


def _infer_keys_by_input_names(
node_def: Union["GraphDefinition", OpDefinition], keys_by_input_name: Mapping[str, AssetKey]
node_def: NodeDefinition, keys_by_input_name: Mapping[str, AssetKey]
) -> Mapping[str, AssetKey]:
all_input_names = [input_def.name for input_def in node_def.input_defs]
if keys_by_input_name:
Expand All @@ -1610,7 +1610,7 @@ def _infer_keys_by_input_names(


def _infer_keys_by_output_names(
node_def: Union["GraphDefinition", OpDefinition],
node_def: NodeDefinition,
keys_by_output_name: Mapping[str, AssetKey],
check_specs_by_output_name: Mapping[str, AssetCheckSpec],
) -> Mapping[str, AssetKey]:
Expand Down

0 comments on commit c943a90

Please sign in to comment.