chore: apply ruff format to bulkhead pool changes

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: Reflex

src/runloop_api_client/_base_client.py

@@ -1847,9 +1847,7 @@ def _ensure_background_client(self, shard: int) -> httpx.AsyncClient:
             except RuntimeError:
                 loop = None
             if loop is not None:
-                transport = _acquire_shared_async_transport(
-                    _shared_async_background_transports, loop, shard
-                )
+                transport = _acquire_shared_async_transport(_shared_async_background_transports, loop, shard)
         client = self._make_bulkhead_client(transport=transport)
         self._background_clients[shard] = client
         return client
@@ -1865,9 +1863,7 @@ def _ensure_transfer_client(self, shard: int) -> httpx.AsyncClient:
             except RuntimeError:
                 loop = None
             if loop is not None:
-                transport = _acquire_shared_async_transport(
-                    _shared_async_transfer_transports, loop, shard
-                )
+                transport = _acquire_shared_async_transport(_shared_async_transfer_transports, loop, shard)
         client = self._make_bulkhead_client(transport=transport)
         self._transfer_clients[shard] = client
         return client

src/runloop_api_client/_client.py

@@ -335,9 +335,7 @@ def copy(
             http_client=http_client,
             shared_http_pool=resolved_shared,
             background_pool_shards=(
-                background_pool_shards
-                if background_pool_shards is not None
-                else self._background_pool_shards
+                background_pool_shards if background_pool_shards is not None else self._background_pool_shards
             ),
             transfer_pool_shards=(
                 transfer_pool_shards if transfer_pool_shards is not None else self._transfer_pool_shards
@@ -645,9 +643,7 @@ def copy(
             http_client=http_client,
             shared_http_pool=resolved_shared,
             background_pool_shards=(
-                background_pool_shards
-                if background_pool_shards is not None
-                else self._background_pool_shards
+                background_pool_shards if background_pool_shards is not None else self._background_pool_shards
             ),
             transfer_pool_shards=(
                 transfer_pool_shards if transfer_pool_shards is not None else self._transfer_pool_shards

tests/test_transfer_client.py

@@ -96,12 +96,8 @@ def test_api_background_transfer_use_distinct_transports() -> None:
 def test_same_resource_affinity_uses_same_shard() -> None:
     client = _make_client(background_pool_shards=2, transfer_pool_shards=2)
     try:
-        w1 = client._send_client_for_request(
-            httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_same/wait_for_status")
-        )
-        w2 = client._send_client_for_request(
-            httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_same/wait_for_status")
-        )
+        w1 = client._send_client_for_request(httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_same/wait_for_status"))
+        w2 = client._send_client_for_request(httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_same/wait_for_status"))
         assert w1 is w2
     finally:
         client.close()
@@ -161,9 +157,7 @@ async def test_async_bulkheads() -> None:
         wait = client._send_client_for_request(
             httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_1/executions/ex_1/wait_for_status")
         )
-        upload = client._send_client_for_request(
-            httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_1/upload_file")
-        )
+        upload = client._send_client_for_request(httpx.Request("POST", f"{base_url}/v1/devboxes/dbx_1/upload_file"))
         assert wait is not client._client
         assert upload is not client._client
         assert wait is not upload