Skip to content

Commit 2b63b3f

Browse files
author
Alan Christie
committed
fix: Minor tweak
1 parent 686254f commit 2b63b3f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

workflow/workflow_engine.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,6 @@ def _handle_pod_message(self, msg: PodMessage) -> None:
166166
variables = response["running_workflow"]["variables"]
167167
assert workflow_id
168168
response = self._api_adapter.get_workflow(workflow_id=workflow_id)
169-
workflow = response["workflow"]
170169

171170
end_of_workflow: bool = True
172171
if success:
@@ -175,6 +174,7 @@ def _handle_pod_message(self, msg: PodMessage) -> None:
175174
# If there are no more steps then the workflow is done
176175
# so we need to set the running workflow as done
177176
# and set it's success status too.
177+
workflow = response["workflow"]
178178
for step in workflow["steps"]:
179179
if step["name"] == step_name:
180180
step_index = workflow["steps"].index(step)

0 commit comments

Comments
 (0)