From 5105cd7591cb11b68d4ce7a08312095989755f34 Mon Sep 17 00:00:00 2001 From: Luciabrightcode Date: Tue, 23 Dec 2025 16:05:47 +0800 Subject: [PATCH] feat(core): implement Headless-Plus Persistence Bridge - Initialize binary Redis client in TaskWorker for msgpack payloads - Implement session state serialization and storage in handle_auth - Implement session state retrieval and deserialization in handle_extract - Update docs to reflect persistence architecture --- src/orchestrator/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)