fix: remove phantom public attribute, unused var, add deprecation comments

- Remove `worker_agent.execution_context` assignment (attribute doesn't
  exist on ChatAgent, only `_execution_context` does)
- Remove unused `total_tokens` local variable
- Add backward-compat comments for duplicate fields
- Fix line-length lint errors

Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]>

Author: fengju0213

camel/societies/workforce/single_agent_worker.py

@@ -430,6 +430,7 @@ def _build_execution_context(
             "borrowed_agent_id": getattr(
                 worker_agent, "agent_id", worker_agent.role_name
             ),
+            # Alias kept for backward compatibility with eigent consumers.
             "agent_id": getattr(
                 worker_agent, "agent_id", worker_agent.role_name
             ),
@@ -441,7 +442,6 @@ def _attach_execution_context(
     ) -> Dict[str, Any]:
         execution_context = self._build_execution_context(task, worker_agent)
         worker_agent._execution_context = execution_context.copy()
-        worker_agent.execution_context = execution_context.copy()
 
         if task.additional_info is None:
             task.additional_info = {}
@@ -484,9 +484,12 @@ def _record_worker_attempt(
             "execution_context": execution_context.copy(),
             "response_content_summary": response_content[:200],
             "tool_calls_summary": tool_calls_summary,
-            "tool_call_count": len(tool_calls) if isinstance(tool_calls, list) else 0,
+            "tool_call_count": (
+                len(tool_calls) if isinstance(tool_calls, list) else 0
+            ),
             "token_usage": token_usage.copy(),
-            # Backward-compatible fields.
+            # Backward-compatible fields — used by eigent task detail UI.
+            # TODO: migrate eigent to *_summary keys, then remove these.
             "response_content": response_content[:50],
             "tool_calls": tool_calls_summary[:50],
             "total_tokens": token_usage.get("total_tokens", 0),
@@ -564,10 +567,12 @@ async def _process_task(
 
                 # Normalize streamed vs non-streamed content for logging and
                 # structured parsing.
-                final_response, response_content, _ = (
-                    await self._consume_worker_response(
-                        response, stream_callback
-                    )
+                (
+                    final_response,
+                    response_content,
+                    _,
+                ) = await self._consume_worker_response(
+                    response, stream_callback
                 )
                 response = final_response
                 task_result = (
@@ -585,10 +590,12 @@ async def _process_task(
                 response = await worker_agent.astep(
                     prompt, response_format=TaskResult
                 )
-                final_response, response_content, parsed_result = (
-                    await self._consume_worker_response(
-                        response, stream_callback
-                    )
+                (
+                    final_response,
+                    response_content,
+                    parsed_result,
+                ) = await self._consume_worker_response(
+                    response, stream_callback
                 )
                 response = final_response
 
@@ -604,7 +611,6 @@ async def _process_task(
                 "token_usage"
             )
             token_usage = usage_info or {"total_tokens": 0}
-            total_tokens = token_usage.get("total_tokens", 0)
 
             # collect conversation from working agent to
             # accumulator for workflow memory

test/workforce/test_workforce_single_agent.py

@@ -124,7 +124,6 @@ def __init__(self, response, agent_id: str = "worker-clone-1"):
         self.role_name = "Fake Worker Agent"
         self.agent_id = agent_id
         self._execution_context = {"stale": "value"}
-        self.execution_context = {"stale": "value"}
         self.astep = AsyncMock(return_value=response)
 
 
@@ -299,7 +298,7 @@ def on_stream(worker_id: str, task_id: str, text: str, mode: str):
 
 
 @pytest.mark.asyncio
-async def test_single_agent_worker_normalizes_delta_stream_and_records_context():
+async def test_single_agent_worker_normalizes_delta_stream_and_ctx():
     sys_msg = BaseMessage.make_assistant_message(
         role_name="programmer",
         content="You are a python programmer.",
@@ -354,19 +353,18 @@ async def test_single_agent_worker_normalizes_delta_stream_and_records_context()
         "agent_id": "worker-clone-1",
         "attempt": 1,
     }
-    assert fake_agent._execution_context == task.additional_info[
-        "execution_context"
-    ]
-    assert fake_agent.execution_context == task.additional_info[
-        "execution_context"
-    ]
+    assert (
+        fake_agent._execution_context
+        == task.additional_info["execution_context"]
+    )
     assert "stale" not in fake_agent._execution_context
 
     worker_attempt = task.additional_info["worker_attempts"][0]
     assert worker_attempt["attempt"] == 1
-    assert worker_attempt["execution_context"] == task.additional_info[
-        "execution_context"
-    ]
+    assert (
+        worker_attempt["execution_context"]
+        == task.additional_info["execution_context"]
+    )
     assert worker_attempt["response_content_summary"] == "Hello"
     assert worker_attempt["tool_call_count"] == 1
     assert worker_attempt["token_usage"] == {
@@ -422,6 +420,7 @@ async def test_single_agent_worker_attempt_counter_uses_existing_attempts():
         "worker-clone-2"
     )
     assert task.additional_info["worker_attempts"][-1]["attempt"] == 2
-    assert task.additional_info["worker_attempts"][-1][
-        "response_content_summary"
-    ] == "Completed"
+    assert (
+        task.additional_info["worker_attempts"][-1]["response_content_summary"]
+        == "Completed"
+    )