Commit a1b40d53 authored by Samuel GAIST's avatar Samuel GAIST

[bcp][worker] Announce disconnection to broker when stopping

parent a7a74713
Pipeline #37582 passed with stage
in 16 minutes and 11 seconds
......@@ -253,6 +253,7 @@ def run(
logger.info("The scheduler shut down, we will wait for it")
worker.destroy()
worker.send_to_broker(BCP.BCPW_DISCONNECT)
worker.destroy()
# Cleanup
for execution_process in execution_processes:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment