Skip to content

Commit 02ad4ea

Browse files
author
Alan Christie
committed
feat: Add dependent_instances to LaunchParameters
1 parent dec6390 commit 02ad4ea

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

workflow/workflow_abc.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,10 @@ class LaunchParameters:
4848
# This cannot be less than 1 and must be grater than any value of
4949
# 'step_replication_number' that will be used fo rthe same step.
5050
total_number_of_replicas: int = 1
51+
# A set of dependent (prior step) instances that are expected to be hard-linked
52+
# into the instance directory the launcher will create. These are required
53+
# so that the step can access the dependent step's files.
54+
dependent_instances: set[str] | None = None
5155
# The application ID (a custom resource name)
5256
# used to identify the 'type' of Instance to create.
5357
# For DM Jobs this will be 'datamanagerjobs.squonk.it'
@@ -185,20 +189,24 @@ def get_running_steps(
185189
def get_status_of_all_step_instances_by_name(
186190
self, *, name: str, running_workflow_id: str
187191
) -> tuple[dict[str, Any], int]:
188-
"""Get a list of step execution statuses for the named step."""
192+
"""Get a list of step execution statuses for the named step.
193+
This includes their step UUID (and instance UUID if available).
194+
"""
189195
# Should return:
190196
# {
191197
# "count": 2,
192198
# "status": [
193199
# {
194200
# "done": True,
195201
# "success": True,
196-
# "running_workflow_step_id": "step-0001"
202+
# "running_workflow_step_id": "step-0001",
203+
# "instance_id": "instance-0001"
197204
# },
198205
# {
199206
# "done": False,
200207
# "success": False,
201-
# "running_workflow_step_id": "step-0002"
208+
# "running_workflow_step_id": "step-0002",
209+
# "instance_id": "instance-0002"
202210
# }
203211
# ]
204212
# }

0 commit comments

Comments
 (0)