Introduce use_async_with_x instead of `connect_to_x(..., use_async=…

…True)`

integration/conftest.py

@@ -215,12 +215,11 @@ async def _factory(
     ) -> weaviate.WeaviateAsyncClient:
         nonlocal client_fixture
         if client_fixture is None:
-            client_fixture = weaviate.connect_to_local(
+            client_fixture = weaviate.use_async_with_local(
                 headers=headers,
                 grpc_port=ports[1],
                 port=ports[0],
                 additional_config=AdditionalConfig(timeout=(60, 120)),  # for image tests
-                use_async=True,
             )
             await client_fixture.connect()
         return client_fixture

integration/test_client.py

@@ -533,14 +533,13 @@ async def test_async_client_with_extra_options(timeout: Union[Tuple[int, int], T
     additional_config = wvc.init.AdditionalConfig(timeout=timeout, trust_env=True)
 
     for client in [
-        weaviate.connect_to_weaviate_cloud(
+        weaviate.use_async_with_weaviate_cloud(
             cluster_url=WCS_URL,
             auth_credentials=WCS_CREDS,
             additional_config=additional_config,
-            use_async=True,
         ),
-        weaviate.connect_to_local(additional_config=additional_config, use_async=True),
-        weaviate.connect_to_custom(
+        weaviate.use_async_with_local(additional_config=additional_config),
+        weaviate.use_async_with_custom(
             http_secure=True,
             http_host=WCS_HOST,
             http_port=443,
@@ -549,7 +548,6 @@ async def test_async_client_with_extra_options(timeout: Union[Tuple[int, int], T
             grpc_port=443,
             auth_credentials=WCS_CREDS,
             additional_config=additional_config,
-            use_async=True,
         ),
     ]:
         await client.connect()
@@ -582,8 +580,8 @@ def test_client_is_ready() -> None:
 
 @pytest.mark.asyncio
 async def test_async_client_is_ready() -> None:
-    async with weaviate.connect_to_weaviate_cloud(
-        cluster_url=WCS_URL, auth_credentials=WCS_CREDS, skip_init_checks=True, use_async=True
+    async with weaviate.use_async_with_weaviate_cloud(
+        cluster_url=WCS_URL, auth_credentials=WCS_CREDS, skip_init_checks=True
     ) as client:
         assert client.is_ready()
 

journey_tests/journeys.py

@@ -1,6 +1,6 @@
 from typing import List
 
-from weaviate import WeaviateAsyncClient, WeaviateClient, connect_to_local
+from weaviate import WeaviateAsyncClient, WeaviateClient, connect_to_local, use_async_with_local
 from weaviate.classes.config import Configure, DataType, Property
 
 
@@ -10,7 +10,7 @@ def __init__(self, client: WeaviateClient) -> None:
 
     @classmethod
     def use(cls) -> "SyncJourneys":
-        return cls(connect_to_local(use_async=False))
+        return cls(connect_to_local())
 
     def close(self) -> None:
         self.__client.close()
@@ -41,7 +41,7 @@ def __init__(self, client: WeaviateAsyncClient) -> None:
 
     @classmethod
     async def use(cls) -> "AsyncJourneys":
-        client = connect_to_local(use_async=True)
+        client = use_async_with_local()
         await client.connect()
         return cls(client)
 

weaviate/__init__.py

@@ -19,6 +19,9 @@
     connect_to_local,
     connect_to_wcs,
     connect_to_weaviate_cloud,
+    use_async_with_custom,
+    use_async_with_local,
+    use_async_with_weaviate_cloud,
 )
 from . import (
     auth,
@@ -71,6 +74,9 @@
     "outputs",
     "schema",
     "types",
+    "use_async_with_custom",
+    "use_async_with_local",
+    "use_async_with_weaviate_cloud",
 ]
 
 deprs = [