Skip to content

Commit

Permalink
make input defs deterministic (#7957)
Browse files Browse the repository at this point in the history
  • Loading branch information
clairelin135 committed May 18, 2022
1 parent f7b14c4 commit 780f771
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion python_modules/dagster/dagster/core/asset_defs/assets_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,9 @@ def build_deps(
node_key = node_name
deps[node_key] = {}
assets_defs_by_node_handle[NodeHandle(alias, parent=None)] = assets_def
for input_name, asset_key in assets_def.asset_keys_by_input_name.items():
for input_name, asset_key in sorted(
assets_def.asset_keys_by_input_name.items(), key=lambda input: input[0]
): # sort so that input definition order is deterministic
if asset_key in node_outputs_by_asset:
node_def, output_name = node_outputs_by_asset[asset_key]
deps[node_key][input_name] = DependencyDefinition(node_def.name, output_name)
Expand Down

0 comments on commit 780f771

Please sign in to comment.