Class Session

app/api/agentops/exporter/models.py:188–240

Session renamed to Trace

class Session(BaseModel):
    """
    Session renamed to Trace
    """

    id: UUID
    project_id: Optional[UUID] = None
    init_timestamp: Optional[datetime] = None
    end_timestamp: Optional[datetime] = None
    tags: Optional[Union[str, list]] = None
    end_state: Optional[str] = None
    end_state_reason: Optional[str] = None
    video: Optional[str] = None
    host_env: Optional[dict] = None
    project_id_secondary: Optional[dict] = None

    async def to_trace(self) -> Trace:
        """Convert a Session to a Trace with spans"""
        span = Span(
            name="session",
            trace_id=str(self.id),
            span_id=str(self.id),  # TODO this is the same as trace_id
            parent_span_id=None,  # parent span has no parent
            kind=SpanKind.SERVER,
            start_time=datetime_to_ns(self.init_timestamp),
            end_time=datetime_to_ns(self.end_timestamp),
            project_id=str(self.project_id),
            service_name=DEFAULT_SERVICE_NAME,
            scope_name=f"{DEFAULT_SCOPE_NAME}.session",
            scope_version=DEFAULT_VERSION,
            resource_attributes={
                "host.name": str(self.host_env) if self.host_env else "unknown",
                "service.name": DEFAULT_SERVICE_NAME,
            },
            span_attributes={
                "session.id": str(self.id),
                "session.end_state": self.end_state or "",
                "session.end_state_reason": self.end_state_reason or "",
            },
        )

        try:
            if self.tags:
                if not isinstance(self.tags, list):
                    self.tags = [self.tags]
                for i, value in enumerate(self.tags):
                    span.span_attributes[f"session.tag.{i}"] = str(value)
        except Exception:
            pass

        trace = Trace(id=self.id)
        trace.spans.append(span)
        return trace


class Agent(BaseModel):