diff --git a/packages/opentelemetry-instrumentation-groq/opentelemetry/instrumentation/groq/__init__.py b/packages/opentelemetry-instrumentation-groq/opentelemetry/instrumentation/groq/__init__.py index daff471dfe..fc57f8e88c 100644 --- a/packages/opentelemetry-instrumentation-groq/opentelemetry/instrumentation/groq/__init__.py +++ b/packages/opentelemetry-instrumentation-groq/opentelemetry/instrumentation/groq/__init__.py @@ -352,7 +352,7 @@ async def _awrap( if is_streaming_response(response): try: - return await _create_async_stream_processor(response, span, event_logger) + return _create_async_stream_processor(response, span, event_logger) except Exception as ex: logger.warning( "Failed to process streaming response for groq span, error: %s",