From 25e1ba70ab932d0334d1e4c8a0a0fa4666b501f1 Mon Sep 17 00:00:00 2001 From: zjgemi Date: Mon, 25 Aug 2025 14:24:15 +0800 Subject: [PATCH 1/2] fix: resubmit workflow with merged output artifact in debug mode Signed-off-by: zjgemi --- src/dflow/workflow.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/dflow/workflow.py b/src/dflow/workflow.py index 670362a1..c4d3018c 100644 --- a/src/dflow/workflow.py +++ b/src/dflow/workflow.py @@ -295,8 +295,9 @@ def submit( and not os.path.islink(os.path.join( wfdir, key)): os.symlink( - os.path.join( - os.path.abspath(step.workflow), key), + os.path.abspath(os.path.join( + config["debug_workdir"], step.workflow, + config["debug_artifact_dir"], key)), os.path.join(wfdir, key)) for name, art in step[io].artifacts.items(): if "dflow_group_key" in step.inputs.parameters: From ff45a80760a38552e66f2867f25b401cc5d580cf Mon Sep 17 00:00:00 2001 From: zjgemi Date: Mon, 25 Aug 2025 14:32:16 +0800 Subject: [PATCH 2/2] fix: format Signed-off-by: zjgemi --- src/dflow/io.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/dflow/io.py b/src/dflow/io.py index 8e59ee73..4a5ae15b 100644 --- a/src/dflow/io.py +++ b/src/dflow/io.py @@ -85,7 +85,8 @@ def eval(self, scope): try: res = eval(self.expr, variables) except Exception: - raise RuntimeError("Failed to evaluate expression %s with variables %s" % (self.expr, variables)) + raise RuntimeError("Failed to evaluate expression %s " + "with variables %s" % (self.expr, variables)) return res