Skip to content

Commit

Permalink
delete
Browse files Browse the repository at this point in the history
  • Loading branch information
schrockn committed Jun 8, 2024
1 parent 3d16e08 commit d173e51
Showing 1 changed file with 0 additions and 42 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -264,48 +264,6 @@ def __init__(
else named_ins_by_asset_key
)

@staticmethod
def from_args(
*, fn: Callable[..., Any], args: DecoratorAssetsDefinitionBuilderArgs
) -> "DecoratorAssetsDefinitionBuilder":
op_name = args.name or fn.__name__

if args.asset_out_map and args.specs:
raise DagsterInvalidDefinitionError("Must specify only outs or specs but not both.")

if args.specs:
check.invariant(
args.decorator_name == "@multi_asset", "Only hit this code path in multi_asset."
)
if args.upstream_asset_deps:
raise DagsterInvalidDefinitionError(
"Can not pass deps and specs to @multi_asset, specify deps on the AssetSpecs"
" directly."
)
if args.asset_deps:
raise DagsterInvalidDefinitionError(
"Can not pass internal_asset_deps and specs to @multi_asset, specify deps on"
" the AssetSpecs directly."
)
return DecoratorAssetsDefinitionBuilder.from_specs(
fn=fn,
op_name=op_name,
passed_args=args,
asset_specs=args.specs,
can_subset=args.can_subset,
asset_in_map=args.asset_in_map,
)

return DecoratorAssetsDefinitionBuilder.from_asset_outs(
fn=fn,
op_name=op_name,
asset_in_map=args.asset_in_map,
asset_out_map=args.asset_out_map,
asset_deps=args.asset_deps,
upstream_asset_deps=args.upstream_asset_deps,
passed_args=args,
)

@staticmethod
def from_specs(
*,
Expand Down

0 comments on commit d173e51

Please sign in to comment.