fix

alpha-unito · Jan 6, 2024 · c14140c · c14140c
1 parent 89ee4a0
commit c14140c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/streamflow/cwl/step.py b/streamflow/cwl/step.py
@@ -150,8 +150,8 @@ async def _load(
             params["skip_ports"].keys(),
             await asyncio.gather(
                 *(
-                    asyncio.create_task(loading_context.load_port(context, value))
-                    for value in params["skip_ports"].values()
+                    asyncio.create_task(loading_context.load_port(context, port_id))
+                    for port_id in params["skip_ports"].values()
                 )
             ),
         ):

diff --git a/streamflow/workflow/step.py b/streamflow/workflow/step.py
@@ -568,7 +568,7 @@ async def _load(
             workflow=await loading_context.load_workflow(context, row["workflow"]),
             job_port=cast(
                 JobPort,
-                await loading_context.load_port(context, params["job_port"]),
+                await loading_context.load_port(context, params["job_port"])
             ),
         )
         step.output_connectors = params["output_connectors"]
@@ -930,7 +930,7 @@ async def _load(
             workflow=await loading_context.load_workflow(context, row["workflow"]),
             job_port=cast(
                 JobPort,
-                await loading_context.load_port(context, params["job_port"]),
+                await loading_context.load_port(context, params["job_port"])
             ),
         )
 
@@ -1236,13 +1236,13 @@ async def _load(
             connector_ports={
                 k: cast(
                     ConnectorPort,
-                    await loading_context.load_port(context, v),
+                    await loading_context.load_port(context, v)
                 )
                 for k, v in params["connector_ports"].items()
             },
             job_port=cast(
                 JobPort,
-                await loading_context.load_port(context, params["job_port"]),
+                await loading_context.load_port(context, params["job_port"])
             ),
             job_prefix=params["job_prefix"],
             hardware_requirement=hardware_requirement,
@@ -1519,7 +1519,7 @@ async def _load(
             workflow=await loading_context.load_workflow(context, row["workflow"]),
             job_port=cast(
                 JobPort,
-                await loading_context.load_port(context, params["job_port"]),
+                await loading_context.load_port(context, params["job_port"])
             ),
         )