File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -189,16 +189,19 @@ async def stop(
189
189
schd .workflow_db_mgr .put_workflow_stop_cycle_point (
190
190
schd .options .stopcp
191
191
)
192
+ schd ._update_workflow_state ()
192
193
elif clock_time is not None :
193
194
# schedule shutdown after wallclock time passes provided time
194
195
parser = TimePointParser ()
195
196
schd .set_stop_clock (
196
197
int (parser .parse (clock_time ).seconds_since_unix_epoch )
197
198
)
199
+ schd ._update_workflow_state ()
198
200
elif task is not None :
199
201
# schedule shutdown after task succeeds
200
202
task_id = TaskID .get_standardised_taskid (task )
201
203
schd .pool .set_stop_task (task_id )
204
+ schd ._update_workflow_state ()
202
205
else :
203
206
# immediate shutdown
204
207
with suppress (KeyError ):
@@ -229,6 +232,7 @@ async def release_hold_point(schd: 'Scheduler'):
229
232
yield
230
233
LOG .info ("Releasing all tasks and removing hold cycle point." )
231
234
schd .pool .release_hold_point ()
235
+ schd ._update_workflow_state ()
232
236
233
237
234
238
@_command ('resume' )
@@ -287,6 +291,7 @@ async def set_hold_point(schd: 'Scheduler', point: str):
287
291
"All tasks after this point will be held."
288
292
)
289
293
schd .pool .set_hold_point (cycle_point )
294
+ schd ._update_workflow_state ()
290
295
291
296
292
297
@_command ('pause' )
You can’t perform that action at this time.
0 commit comments