otel log service errors

This commit is contained in:
Ishaan Jaff 2024-08-05 20:21:26 -07:00
parent bf72b7e567
commit 8da555a2d9

View file

@ -165,6 +165,7 @@ class OpenTelemetry(CustomLogger):
async def async_service_failure_hook( async def async_service_failure_hook(
self, self,
payload: ServiceLoggerPayload, payload: ServiceLoggerPayload,
error: Optional[str] = "",
parent_otel_span: Optional[Span] = None, parent_otel_span: Optional[Span] = None,
start_time: Optional[Union[datetime, float]] = None, start_time: Optional[Union[datetime, float]] = None,
end_time: Optional[Union[float, datetime]] = None, end_time: Optional[Union[float, datetime]] = None,
@ -199,6 +200,8 @@ class OpenTelemetry(CustomLogger):
service_logging_span.set_attribute( service_logging_span.set_attribute(
key="service", value=payload.service.value key="service", value=payload.service.value
) )
if error:
service_logging_span.set_attribute(key="error", value=error)
if event_metadata: if event_metadata:
for key, value in event_metadata.items(): for key, value in event_metadata.items():
if isinstance(value, dict): if isinstance(value, dict):