remove log body stamping

Author: aabmass

util/opentelemetry-util-genai/src/opentelemetry/util/genai/_fsspec_upload/fsspec_hook.py

@@ -199,19 +199,11 @@ def to_dict(
         if span:
             span.set_attributes(references)
         if log_record:
-            # set in both attributes and body until they are consolidated
-            # https://github.com/open-telemetry/semantic-conventions/issues/1870
             log_record.attributes = {
                 **(log_record.attributes or {}),
                 **references,
             }
 
-            if log_record.body is None or isinstance(log_record.body, Mapping):
-                log_record.body = {
-                    **(log_record.body or {}),
-                    **references,
-                }
-
     def shutdown(self) -> None:
         # TODO: support timeout
         self._executor.shutdown()

util/opentelemetry-util-genai/tests/test_fsspec_upload.py

@@ -229,7 +229,6 @@ def test_upload_completions(self):
         for attributes in [
             span.attributes,
             log_record.attributes,
-            log_record.body,
         ]:
             for ref_key in [
                 "gen_ai.input.messages_ref",
@@ -273,21 +272,3 @@ def test_stamps_empty_log(self):
         self.assertIn("gen_ai.input.messages_ref", log_record.attributes)
         self.assertIn("gen_ai.output.messages_ref", log_record.attributes)
         self.assertIn("gen_ai.system_instructions_ref", log_record.attributes)
-        self.assertIn("gen_ai.input.messages_ref", log_record.body)
-        self.assertIn("gen_ai.output.messages_ref", log_record.body)
-        self.assertIn("gen_ai.system_instructions_ref", log_record.body)
-
-    def test_stamps_log_with_map_body(self):
-        log_record = LogRecord(body={"hello": "world"})
-        self.upload_with_log(log_record)
-
-        # stamp on both body and attributes, preserving existing
-        self.assertEqual(log_record.body["hello"], "world")
-        self.assertIn("gen_ai.input.messages_ref", log_record.body)
-        self.assertIn("gen_ai.output.messages_ref", log_record.body)
-        self.assertIn("gen_ai.system_instructions_ref", log_record.body)
-
-    def test_doesnt_stamp_log_string_body(self):
-        log_record = LogRecord(body="hello world")
-        self.upload_with_log(log_record)
-        self.assertEqual(log_record.body, "hello world")