Cleaning out agent protocol

newrelic/core/agent_protocol.py

@@ -603,7 +603,7 @@ def _to_http(self, method, payload=()):
             for event in event_data:
                 event_info, event_attrs = event
                 event_attrs.update({"event.domain": "newrelic.ml_events", "event.name": event_info["type"]})
-                ml_attrs = [self._create_key_value(key, value) for key, value in event_attrs.items()]
+                ml_attrs = [create_key_value(key, value) for key, value in event_attrs.items()]
                 ml_attrs = [key_value for key_value in ml_attrs if key_value]
                 ml_events.append(
                     {
@@ -615,18 +615,3 @@ def _to_http(self, method, payload=()):
             payload = LogsData(resource_logs=[ResourceLogs(scope_logs=[ScopeLogs(log_records=ml_events)])])
             return params, self._headers, payload.SerializeToString()
         return params, self._headers, json_encode(payload).encode("utf-8")
-
-    def _create_key_value(self, key, value):
-        if isinstance(value, bool):
-            return KeyValue(key=key, value=AnyValue(bool_value=value))
-        elif isinstance(value, int):
-            return KeyValue(key=key, value=AnyValue(int_value=value))
-        elif isinstance(value, float):
-            return KeyValue(key=key, value=AnyValue(double_value=value))
-        elif isinstance(value, str):
-            return KeyValue(key=key, value=AnyValue(string_value=value))
-        # Techincally AnyValue accepts array, kvlist, and bytes however, since
-        # those are not valid custom attribute types according to our api spec,
-        # we will not bother to support them here either.
-        else:
-            _logger.warn("Unsupported ML event attribute value type %s: %s." % (key, value))