diff --git a/src/orchestrator/worker.py b/src/orchestrator/worker.py index e0a9317..f6b7c6f 100644 --- a/src/orchestrator/worker.py +++ b/src/orchestrator/worker.py @@ -17,7 +17,7 @@ logger = logging.getLogger("TaskWorker") class TaskWorker: def __init__(self, redis_url: str): self.redis = redis.from_url(redis_url, decode_responses=True) - # Binary client for MessagePack payload (SessionState) + # Binary client for MessagePack payload (SessionState) - Headless-Plus Store self.redis_raw = redis.from_url(redis_url, decode_responses=False) self.scheduler = EntropyScheduler() self.recovery = SessionRecoveryManager(self)