Fix util-genai tests and pre-commit formatting

Author: srikaaviya

instrumentation/opentelemetry-instrumentation-asyncio/tests/test_asyncio_run_coroutine_threadsafe.py

@@ -12,11 +12,12 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import asyncio
-import threading
+
 # from concurrent.futures import (  # pylint: disable=no-name-in-module; TODO #4199
 #     ThreadPoolExecutor,
 # )
 import concurrent.futures
+import threading
 from unittest.mock import patch
 
 # pylint: disable=no-name-in-module

instrumentation/opentelemetry-instrumentation-threading/tests/test_threading.py

@@ -12,19 +12,19 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import threading
-# from concurrent.futures import (  # pylint: disable=no-name-in-module; TODO #4199
-#     ThreadPoolExecutor,
-# )
-
 import concurrent.futures
+import threading
 from typing import List
 from unittest.mock import MagicMock, patch
 
 from opentelemetry import trace
 from opentelemetry.instrumentation.threading import ThreadingInstrumentor
 from opentelemetry.test.test_base import TestBase
 
+# from concurrent.futures import (  # pylint: disable=no-name-in-module; TODO #4199
+#     ThreadPoolExecutor,
+# )
+
 
 # pylint: disable=too-many-public-methods
 class TestThreading(TestBase):
@@ -65,7 +65,9 @@ def test_trace_context_propagation_in_thread_pool_with_multiple_workers(
         self,
     ):
         max_workers = 10
-        executor = concurrent.futures.ThreadPoolExecutor(max_workers=max_workers)
+        executor = concurrent.futures.ThreadPoolExecutor(
+            max_workers=max_workers
+        )
 
         expected_span_contexts: List[trace.SpanContext] = []
         futures_list = []
@@ -85,7 +87,9 @@ def test_trace_context_propagation_in_thread_pool_with_multiple_workers(
 
     def test_trace_context_propagation_in_thread_pool_with_single_worker(self):
         max_workers = 1
-        with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
+        with concurrent.futures.ThreadPoolExecutor(
+            max_workers=max_workers
+        ) as executor:
             # test propagation of the same trace context across multiple tasks
             with self._tracer.start_as_current_span("task") as task_span:
                 expected_task_context = task_span.get_span_context()

util/opentelemetry-util-genai/src/opentelemetry/util/genai/_upload/completion_hook.py

@@ -15,18 +15,18 @@
 
 from __future__ import annotations
 
+# from concurrent.futures import (  # pylint: disable=no-name-in-module; TODO #4199
+#     Future,
+#     ThreadPoolExecutor,
+# )
+import concurrent.futures
 import dataclasses
 import hashlib
 import json
 import logging
 import posixpath
 import threading
 from collections import OrderedDict
-# from concurrent.futures import (  # pylint: disable=no-name-in-module; TODO #4199
-#     Future,
-#     ThreadPoolExecutor,
-# )
-import concurrent.futures
 from contextlib import ExitStack
 from dataclasses import asdict, dataclass
 from functools import partial
@@ -314,10 +314,12 @@ def on_completion(
         )
 
         def to_dict(
-            dataclass_list: list[types.InputMessage]
-            | list[types.OutputMessage]
-            | list[types.MessagePart]
-            | list[types.ToolDefinition],
+            dataclass_list: (
+                list[types.InputMessage]
+                | list[types.OutputMessage]
+                | list[types.MessagePart]
+                | list[types.ToolDefinition]
+            ),
         ) -> JsonEncodeable:
             return [asdict(dc) for dc in dataclass_list]
 

util/opentelemetry-util-genai/tests/test_upload.py

@@ -307,7 +307,7 @@ def test_upload_after_shutdown_logs(self):
     def test_threadpool_max_workers(self):
         for max_queue_size, expect_threadpool_workers in ((10, 10), (100, 64)):
             with patch(
-                "opentelemetry.util.genai._upload.completion_hook.ThreadPoolExecutor"
+                "opentelemetry.util.genai._upload.completion_hook.concurrent.futures.ThreadPoolExecutor"
             ) as mock:
                 hook = UploadCompletionHook(
                     base_path=BASE_PATH, max_queue_size=max_queue_size