wip
This commit is contained in:
@@ -366,8 +366,11 @@ def manager_cleanup() -> None:
|
||||
|
||||
cloudlog.info("everything is dead")
|
||||
|
||||
last_running = ""
|
||||
|
||||
def manager_thread(frogpilot_functions) -> None:
|
||||
global last_running
|
||||
|
||||
cloudlog.bind(daemon="manager")
|
||||
cloudlog.info("manager start")
|
||||
cloudlog.info({"environ": os.environ})
|
||||
@@ -419,8 +422,12 @@ def manager_thread(frogpilot_functions) -> None:
|
||||
|
||||
running = ' '.join("{}{}\u001b[0m".format("\u001b[32m" if p.proc.is_alive() else "\u001b[31m", p.name)
|
||||
for p in managed_processes.values() if p.proc)
|
||||
print(running)
|
||||
cloudlog.debug(running)
|
||||
|
||||
# clearpilot
|
||||
if (running != last_running):
|
||||
print(running)
|
||||
cloudlog.debug(running)
|
||||
last_running = running
|
||||
|
||||
# send managerState
|
||||
msg = messaging.new_message('managerState', valid=True)
|
||||
|
||||
Reference in New Issue
Block a user