@@ -112,9 +112,16 @@ def get_running_workflow(
112
112
# "success": false,
113
113
# "error": None,
114
114
# "error_msg": None,
115
- # "workflow": {"id": "workflow-000"},
116
- # "project_id": "project-000",
117
- # "variables": {"x": 1, "y": 2},
115
+ # "workflow": {
116
+ # "id": "workflow-000",
117
+ # },
118
+ # "project": {
119
+ # "id": "project-000",
120
+ # },
121
+ # "variables": {
122
+ # "x": 1,
123
+ # "y": 2,
124
+ # },
118
125
# }
119
126
# }
120
127
# If not present an empty dictionary should be returned.
@@ -157,7 +164,9 @@ def get_running_workflow_step(
157
164
# "success": false,
158
165
# "error": None,
159
166
# "error_msg": None,
160
- # "running_workflow": "r-workflow-00000000-0000-0000-0000-000000000001",
167
+ # "running_workflow": {
168
+ # "id": "r-workflow-00000000-0000-0000-0000-000000000001"
169
+ # },
161
170
# },
162
171
# }
163
172
# If not present an empty dictionary should be returned.
@@ -177,9 +186,13 @@ def set_running_workflow_step_done(
177
186
@abstractmethod
178
187
def get_instance (self , * , instance_id : str ) -> tuple [dict [str , Any ], int ]:
179
188
"""Get an Instance Record"""
180
- # Should return:
189
+ # For a RunningWorkflowStep Instance it should return:
181
190
# {
182
- # "running_workflow_step": "r-workflow-step-00000000-0000-0000-0000-000000000001",
191
+ # "id": "instance-00000000-0000-0000-0000-000000000001",
192
+ # "running_workflow_step": {
193
+ # "id": "r-workflow-step-00000000-0000-0000-0000-000000000001",
194
+ # "step": "step-1234",
195
+ # },
183
196
# [...],
184
197
# }
185
198
# If not present an empty dictionary should be returned.
0 commit comments