fix: span event to dict conversion (#3009)

src/phoenix/db/bulk_inserter.py

@@ -1,5 +1,6 @@
 import asyncio
 import logging
+from dataclasses import asdict
 from datetime import datetime, timezone
 from itertools import islice
 from time import time
@@ -295,7 +296,7 @@ async def _insert_span(session: AsyncSession, span: Span, project_name: str) ->
             start_time=span.start_time,
             end_time=span.end_time,
             attributes=span.attributes,
-            events=span.events,
+            events=[asdict(event) for event in span.events],
             status_code=span.status_code.value,
             status_message=span.status_message,
             cumulative_error_count=cumulative_error_count,

src/phoenix/server/api/types/Span.py

@@ -90,7 +90,7 @@ def from_dict(
         return SpanEvent(
             name=event["name"],
             message=cast(str, event["attributes"].get(trace_schema.EXCEPTION_MESSAGE) or ""),
-            timestamp=event["timestamp"],
+            timestamp=datetime.fromisoformat(event["timestamp"]),
         )
 
 

src/phoenix/trace/schemas.py

@@ -1,7 +1,7 @@
 from dataclasses import dataclass
 from datetime import datetime
 from enum import Enum
-from typing import Any, Dict, List, Mapping, NamedTuple, Optional
+from typing import Any, List, Mapping, NamedTuple, Optional
 from uuid import UUID
 
 EXCEPTION_TYPE = "exception.type"
@@ -71,7 +71,7 @@ class SpanConversationAttributes:
 
 
 @dataclass(frozen=True)
-class SpanEvent(Dict[str, Any]):
+class SpanEvent:
     """
     A Span Event can be thought of as a structured log message (or annotation)
     on a Span, typically used to denote a meaningful, singular point in time