fix: Better handling of get_running_workflow_step_by_name() response

Alan Christie · Alan Christie · commit 3fe5969024ae · 2025-09-25T07:43:59.000Z
diff --git a/workflow/workflow_engine.py b/workflow/workflow_engine.py
@@ -609,6 +609,8 @@ def _prepare_step(
                 name=prior_step_name,
                 running_workflow_id=rwf_id,
             )
+            assert prior_step
+            assert "variables" in prior_step
             # Copy "in" value to "out"...
             for connector in connections:
                 assert connector.in_ in prior_step["variables"]

Original file line number	Diff line number	Diff line change
`@@ -609,6 +609,8 @@ def _prepare_step(`
`609`	`609`	`name=prior_step_name,`
`610`	`610`	`running_workflow_id=rwf_id,`
`611`	`611`	`)`
	`612`	`+ assert prior_step`
	`613`	`+ assert "variables" in prior_step`
`612`	`614`	`# Copy "in" value to "out"...`
`613`	`615`	`for connector in connections:`
`614`	`616`	`assert connector.in_ in prior_step["variables"]`