fix(adk): warn when record_usage replaces non-dict span data

Author: levilentz

src/agentex/lib/adk/_modules/tracing.py

@@ -93,6 +93,11 @@ def record_usage(
             )
         )
 
+        if self.span.data is not None and not isinstance(self.span.data, dict):
+            logger.warning(
+                f"TurnSpan.record_usage: span.data is {type(self.span.data).__name__} "
+                "(expected dict or None); existing data will be replaced."
+            )
         data = self.span.data if isinstance(self.span.data, dict) else {}
         if blob:
             data["usage"] = blob

tests/lib/adk/test_tracing_module.py

@@ -321,6 +321,34 @@ async def test_turn_span_preserves_existing_data(self):
         assert ended_span.data["custom"] == "value"
         assert ended_span.data["usage"] == {"prompt_tokens": 3, "completion_tokens": 4}
 
+    async def test_turn_span_warns_and_replaces_non_dict_data(self, caplog):
+        mock_service, module = _make_module()
+        started = _make_span(data=[{"item": 1}])
+        mock_service.start_span.return_value = started
+        mock_service.end_span.return_value = started
+
+        with patch.object(_tracing_mod, "in_temporal_workflow", return_value=False):
+            async with module.turn_span(trace_id="trace-123", name="turn") as turn:
+                with caplog.at_level("WARNING"):
+                    turn.record_usage(usage={"input_tokens": 1, "output_tokens": 2})
+
+        assert any("existing data will be replaced" in message for message in caplog.messages)
+        ended_span = mock_service.end_span.call_args.kwargs["span"]
+        assert ended_span.data == {"usage": {"input_tokens": 1, "output_tokens": 2}}
+
+    async def test_turn_span_dict_data_does_not_warn(self, caplog):
+        mock_service, module = _make_module()
+        started = _make_span(data={"custom": "value"})
+        mock_service.start_span.return_value = started
+        mock_service.end_span.return_value = started
+
+        with patch.object(_tracing_mod, "in_temporal_workflow", return_value=False):
+            async with module.turn_span(trace_id="trace-123", name="turn") as turn:
+                with caplog.at_level("WARNING"):
+                    turn.record_usage(usage={"input_tokens": 1})
+
+        assert not any("existing data will be replaced" in message for message in caplog.messages)
+
     async def test_turn_span_cost_only(self):
         mock_service, module = _make_module()
         started = _make_span()