WIP: fixing the lint in files.

Author: eternalcuriouslearner

instrumentation-genai/opentelemetry-instrumentation-openai-v2/src/opentelemetry/instrumentation/openai_v2/patch_responses.py

@@ -14,18 +14,9 @@
 
 from __future__ import annotations
 
-from typing import Optional
-
-from opentelemetry.semconv._incubating.attributes import (
-    gen_ai_attributes as GenAIAttributes,
-)
-from opentelemetry.semconv._incubating.attributes import (
-    server_attributes as ServerAttributes,
-)
 from opentelemetry.util.genai.handler import TelemetryHandler
 from opentelemetry.util.genai.types import ContentCapturingMode, Error
 
-from .instruments import Instruments
 from .response_extractors import (
     _apply_request_attributes,
     _get_inference_creation_kwargs,

instrumentation-genai/opentelemetry-instrumentation-openai-v2/src/opentelemetry/instrumentation/openai_v2/response_extractors.py

@@ -38,6 +38,8 @@
     server_attributes as ServerAttributes,
 )
 
+from .utils import get_server_address_and_port, value_is_set
+
 _PYDANTIC_V2 = hasattr(BaseModel, "model_validate")
 
 if _PYDANTIC_V2:
@@ -70,8 +72,6 @@
     Text = None
     ToolCall = None
 
-from .utils import get_server_address_and_port, value_is_set
-
 GEN_AI_USAGE_CACHE_READ_INPUT_TOKENS = "gen_ai.usage.cache_read.input_tokens"
 GEN_AI_USAGE_CACHE_CREATION_INPUT_TOKENS = (
     "gen_ai.usage.cache_creation.input_tokens"

instrumentation-genai/opentelemetry-instrumentation-openai-v2/tests/test_response_wrappers.py

@@ -372,13 +372,13 @@ async def test_async_stream_wrapper_processes_events_and_stops_on_completion():
     wrapper.process_event = processed.append
     wrapper._stop = stopped.append
 
-    result = await wrapper.__anext__()
+    result = await anext(wrapper)
 
     assert result is event
     assert processed == [event]
 
     with pytest.raises(StopAsyncIteration):
-        await wrapper.__anext__()
+        await anext(wrapper)
 
     assert stopped == [None]
 
@@ -417,7 +417,7 @@ def record_failure(message, error_type):
     wrapper._fail = record_failure
 
     with pytest.raises(ValueError, match="boom"):
-        await wrapper.__anext__()
+        await anext(wrapper)
 
     assert failures == [("boom", ValueError)]
 

instrumentation-genai/opentelemetry-instrumentation-openai-v2/tests/test_responses.py

@@ -45,6 +45,10 @@
 )
 
 try:
+    # Responses is not available in the oldest supported OpenAI SDK, so keep
+    # this import guarded. Pylint runs against the oldest dependency set and
+    # cannot resolve this optional module there.
+    # pylint: disable-next=no-name-in-module
     from openai.resources.responses.responses import Responses as _Responses
 
     HAS_RESPONSES_API = True
@@ -329,7 +333,7 @@ def test_responses_create_connection_error(span_exporter, instrument_no_content)
     client = OpenAI(base_url="http://localhost:4242")
 
     with pytest.raises(APIConnectionError):
-        client.responses.create(
+        client.responses.create(  # pylint: disable=no-member
             model=DEFAULT_MODEL,
             input="Hello",
             timeout=0.1,
@@ -476,7 +480,7 @@ def test_responses_create_streaming_connection_error(
     client = OpenAI(base_url="http://localhost:4242")
 
     with pytest.raises(APIConnectionError):
-        client.responses.create(
+        client.responses.create(  # pylint: disable=no-member
             model=DEFAULT_MODEL,
             input="Hello",
             stream=True,

instrumentation-genai/opentelemetry-instrumentation-openai-v2/tests/test_utils.py

@@ -15,12 +15,8 @@
 """Shared test utilities for OpenAI instrumentation tests."""
 
 import json
-import os
-from pathlib import Path
 from typing import Any, Optional
 
-import pytest
-
 from opentelemetry.instrumentation.openai_v2.response_extractors import (
     GEN_AI_USAGE_CACHE_CREATION_INPUT_TOKENS,
     GEN_AI_USAGE_CACHE_READ_INPUT_TOKENS,