|
|
@ -140,8 +140,8 @@ def manager_thread() -> None: |
|
|
|
|
|
|
|
|
|
|
|
running = ' '.join("%s%s\u001b[0m" % ("\u001b[32m" if p.proc.is_alive() else "\u001b[31m", p.name) |
|
|
|
running = ' '.join("%s%s\u001b[0m" % ("\u001b[32m" if p.proc.is_alive() else "\u001b[31m", p.name) |
|
|
|
for p in managed_processes.values() if p.proc) |
|
|
|
for p in managed_processes.values() if p.proc) |
|
|
|
print(running) |
|
|
|
# print(running) |
|
|
|
cloudlog.debug(running) |
|
|
|
# cloudlog.debug(running) |
|
|
|
|
|
|
|
|
|
|
|
# send managerState |
|
|
|
# send managerState |
|
|
|
msg = messaging.new_message('managerState') |
|
|
|
msg = messaging.new_message('managerState') |
|
|
|