diff --git a/src/dflow/step.py b/src/dflow/step.py index 9a7b148b..dabb0b60 100644 --- a/src/dflow/step.py +++ b/src/dflow/step.py @@ -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) @@ -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 = \