From 760377703a84e782ee54aed07d564d1a9410041f Mon Sep 17 00:00:00 2001 From: EMRG Evolution Date: Sun, 26 Jul 2026 06:02:56 +0800 Subject: [PATCH] emrg: remove unreachable task handler from _process_message _handle_client already intercepts 'task' messages before delegating to _process_message, making the task branch in _process_message dead code. 420 tests pass. --- emrg/server/daemon.py | 36 ------------------------------------ 1 file changed, 36 deletions(-) diff --git a/emrg/server/daemon.py b/emrg/server/daemon.py index ae26de3b..39fa1152 100644 --- a/emrg/server/daemon.py +++ b/emrg/server/daemon.py @@ -655,42 +655,6 @@ async def _process_message( }) return - elif msg_type == "task": - session_id = msg.get("session_id", "") - cwd = msg.get("cwd", "") - - if not session_id or not cwd: - await self._send(writer, { - "error": "task requires session_id and cwd", - }) - return - - try: - req = TaskRequest( - id=msg.get("id", ""), - session_id=session_id, - cwd=cwd, - prompt=msg.get("prompt", ""), - timestamp=msg.get("timestamp", ""), - stream=msg.get("stream", False), - ) - except Exception as e: - await self._send(writer, {"error": f"invalid task: {e}"}) - return - - # Load or create session - session = self._get_or_create_session(session_id, Path(cwd)) - - logger.info( - 'task received: session=%s prompt="%s" → routing via LLM (stream=%s)', - session_id, req.prompt[:60], req.stream, - ) - - if req.stream: - await self._run_tool_loop(req, writer, session) - else: - await self._run_chat_once(req, writer, session) - elif msg_type == "compact": cwd = msg.get("cwd", "") session_id = msg.get("session_id", "")