Skip to content

Commit

Permalink
Make AssetChecksDefinition.create call trivially stacked on builder p…
Browse files Browse the repository at this point in the history
…roperties in multi_asset_check
  • Loading branch information
schrockn committed Jun 12, 2024
1 parent dd28610 commit c37f2f6
Showing 1 changed file with 4 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -365,13 +365,10 @@ def inner(fn: MultiAssetCheckFunction) -> AssetChecksDefinition:

return AssetChecksDefinition.create(
node_def=op_def,
resource_defs=wrap_resources_for_execution(resource_defs),
keys_by_input_name={
input_tuple[0]: asset_key
for asset_key, input_tuple in named_ins_by_asset_key.items()
},
check_specs_by_output_name={spec.get_python_identifier(): spec for spec in specs},
can_subset=can_subset,
resource_defs=builder.args.op_def_resource_defs,
keys_by_input_name=builder.asset_keys_by_input_name,
check_specs_by_output_name=builder.check_specs_by_output_name,
can_subset=builder.args.can_subset,
)

return inner

0 comments on commit c37f2f6

Please sign in to comment.