Skip to content

Commit

Permalink
fix: We need not input artifact path for a step
Browse files Browse the repository at this point in the history
Signed-off-by: zjgemi <[email protected]>
  • Loading branch information
zjgemi committed Nov 20, 2023
1 parent cf97746 commit 9374e2a
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/dflow/step.py
Original file line number Diff line number Diff line change
Expand Up @@ -358,6 +358,9 @@ def __init__(
self.template.set_slices(self.template.slices)

self.inputs = deepcopy(self.template.inputs)
# We need not input artifact path for a step
for art in self.inputs.artifacts.values():
art.path = None
self.outputs = deepcopy(self.template.outputs)
self.inputs.set_step(self)
self.outputs.set_step(self)
Expand Down Expand Up @@ -585,9 +588,6 @@ def merge_output_artifact(art):
for name in sliced_input_artifact:
self.inputs.parameters["dflow_%s_sub_path" %
name].value = "{{item.%s}}" % name
# step cannot resolve
# {{inputs.parameters.dflow_%s_sub_path}}
self.inputs.artifacts[name].path = None
v = self.inputs.artifacts[name].source
if isinstance(v, S3Artifact):
self.prepare_step.inputs.artifacts[name].source = \
Expand Down

0 comments on commit 9374e2a

Please sign in to comment.