changed injection of tokens

LanderOtto · LanderOtto · commit d536040a0833 · 2026-02-02T11:43:12.000+01:00
diff --git a/streamflow/recovery/policy/recovery.py b/streamflow/recovery/policy/recovery.py
@@ -59,9 +59,7 @@ async def _execute_recover_workflow(new_workflow: Workflow, failed_step: Step) -
 
 
 async def _inject_tokens(mapper: GraphMapper, new_workflow: Workflow) -> None:
-    for port_name in [
-        p for p, degree in mapper.dcg_port.in_degree().items() if degree == 0
-    ]:
+    for port_name in mapper.port_tokens.keys():
         token_list = sorted(
             [
                 mapper.token_instances[token_id]

Original file line number	Diff line number	Diff line change
`@@ -59,9 +59,7 @@ async def _execute_recover_workflow(new_workflow: Workflow, failed_step: Step) -`
`59`	`59`
`60`	`60`
`61`	`61`	`async def _inject_tokens(mapper: GraphMapper, new_workflow: Workflow) -> None:`
`62`		`- for port_name in [`
`63`		`- p for p, degree in mapper.dcg_port.in_degree().items() if degree == 0`
`64`		`- ]:`
	`62`	`+ for port_name in mapper.port_tokens.keys():`
`65`	`63`	`token_list = sorted(`
`66`	`64`	`[`
`67`	`65`	`mapper.token_instances[token_id]`