minor fixes

This commit is contained in:
Dinesh Yeduguru 2024-11-30 17:23:24 -08:00
parent 94b4113c63
commit e5c85b9dba
3 changed files with 3 additions and 5 deletions

View file

@ -190,5 +190,5 @@ class Telemetry(Protocol):
async def export_agent_trace(
self,
session_ids: List[str],
dataset_id: str = None,
dataset_id: str,
) -> None: ...

View file

@ -63,7 +63,7 @@ class ConsoleTelemetryImpl(Telemetry):
async def export_agent_trace(
self,
session_ids: List[str],
dataset_id: str = None,
dataset_id: str,
) -> None:
raise NotImplementedError(
"Console telemetry does not support agent trace export"

View file

@ -223,9 +223,7 @@ class OpenTelemetryAdapter(Telemetry):
return traces
async def export_agent_trace(
self, session_ids: List[str], dataset_id: str = None
) -> None:
async def export_agent_trace(self, session_ids: List[str], dataset_id: str) -> None:
traces = await self.get_agent_trace(session_ids)
traces_dict = [
{