From 9d25dc71ac35a25072487a8d0a057e4398a059d2 Mon Sep 17 00:00:00 2001 From: Muhammad Rashid Date: Sun, 5 Apr 2026 15:53:45 -0400 Subject: [PATCH] fix: remove incorrect await on async generator in Groq streaming _create_async_stream_processor is an async generator (uses yield), so it cannot be awaited. Awaiting it raises: TypeError: object async_generator can't be used in 'await' expression The sync counterpart (_create_stream_processor) correctly returns without await on line 272. This fix makes the async path consistent. --- .../opentelemetry/instrumentation/groq/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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",