diff --git a/orchestrator/main.py b/orchestrator/main.py index a22ef50..9bb6cac 100644 --- a/orchestrator/main.py +++ b/orchestrator/main.py @@ -1,5 +1,6 @@ import json import threading +import time from redis_client import get_redis_client from result_listener import listen_for_results @@ -34,13 +35,17 @@ def main(): ) listener.start() - print("orchestrator ready") + print("[orchestrator] ready") while True: try: command = input("> ").strip() - except (EOFError, KeyboardInterrupt): + except EOFError: + print("[orchestrator] stdin closed, waiting...") + time.sleep(2) + continue + except KeyboardInterrupt: print() - break + continue if not command: continue