Skip to content

Commit 04f57d2

Browse files
author
Alan Christie
committed
fix: Fix input output hanes in decoder
1 parent c6a34e8 commit 04f57d2

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

workflow/decoder.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -107,8 +107,10 @@ def get_step_output_variable_names(
107107
variable_names: list[str] = []
108108
steps: list[dict[str, Any]] = get_steps(definition)
109109
for step in steps:
110-
if step["name"] == step_name:
111-
variable_names.extend(step.get("out", []))
110+
if step["name"] == step_name and "plumbing" in step:
111+
for v_map in step["plumbing"]:
112+
if "to-project" in v_map:
113+
variable_names.append(v_map["variable"])
112114
return variable_names
113115

114116

@@ -122,8 +124,10 @@ def get_step_input_variable_names(
122124
variable_names: list[str] = []
123125
steps: list[dict[str, Any]] = get_steps(definition)
124126
for step in steps:
125-
if step["name"] == step_name:
126-
variable_names.extend(step.get("in", []))
127+
if step["name"] == step_name and "plumbing" in step:
128+
for v_map in step["plumbing"]:
129+
if "from-project" in v_map:
130+
variable_names.append(v_map["variable"])
127131
return variable_names
128132

129133

0 commit comments

Comments
 (0)