Remove uvloop blockers

Author: awalker4

_test_unstructured_client/integration/test_integration.py

@@ -188,6 +188,7 @@ async def test_partition_async_processes_concurrent_files(client, doc_path):
 
 
 def test_uvloop_partitions_without_errors(client, doc_path):
+    """Test that we can use pdf splitting within another asyncio loop."""
     async def call_api():
         filename = "layout-parser-paper-fast.pdf"
         with open(doc_path / filename, "rb") as f:

gen.yaml

@@ -29,7 +29,6 @@ python:
       pytest-mock: '>=3.14.0'
       pytest-xdist: ^3.5.0
       types-aiofiles: '>=24.1.0'
-      uvloop: '>=0.20.0'
     main:
       aiofiles: '>=24.1.0'
       cryptography: '>=3.1'

src/unstructured_client/_hooks/custom/split_pdf_hook.py

@@ -117,16 +117,6 @@ async def run_tasks(
         return sorted(results, key=lambda x: x[0])
 
 
-def context_is_uvloop():
-    """Return true if uvloop is installed and we're currently in a uvloop context. Our asyncio splitting code currently doesn't work under uvloop."""
-    try:
-        import uvloop  # type: ignore[import]  # pylint: disable=import-outside-toplevel
-        loop = asyncio.get_event_loop()
-        return isinstance(loop, uvloop.Loop)
-    except (ImportError, RuntimeError):
-        return False
-
-
 def get_optimal_split_size(num_pages: int, concurrency_level: int) -> int:
     """Distributes pages to workers evenly based on the number of pages and desired concurrency level."""
     if num_pages < MAX_PAGES_PER_SPLIT * concurrency_level:
@@ -273,10 +263,6 @@ def before_request(
             logger.warning("HTTP client not accessible! Continuing without splitting.")
             return request
 
-        if context_is_uvloop():
-            logger.warning("Splitting is currently incompatible with uvloop. Continuing without splitting.")
-            return request
-
         # This is our key into coroutines_to_execute
         # We need to pass it on to after_success so
         # we know which results are ours