Undo server_url changes for platform

Author: awalker4

.genignore

@@ -9,9 +9,5 @@ _test_unstructured_client
 # ignore Makefile
 Makefile
 
-# Ignore the endpoint files until we can fix the base_url issue
-src/unstructured_client/destinations.py
+# Ignore the general.partition code until we can fix the base_url issue
 src/unstructured_client/general.py
-src/unstructured_client/jobs.py
-src/unstructured_client/sources.py
-src/unstructured_client/workflows.py

_test_unstructured_client/unit/test_server_urls.py

@@ -58,25 +58,6 @@ def mock_build_request(*args, base_url, **kwargs):
     "sdk_endpoint_name",
     [
         ("general.partition"),
-        ("destinations.create_destination"),
-        ("destinations.delete_destination"),
-        ("destinations.get_destination"),
-        ("destinations.list_destinations"),
-        ("destinations.update_destination"),
-        ("jobs.cancel_job"),
-        ("jobs.get_job"),
-        ("jobs.list_jobs"),
-        ("sources.create_source"),
-        ("sources.delete_source"),
-        ("sources.get_source"),
-        ("sources.list_sources"),
-        ("sources.update_source"),
-        ("workflows.create_workflow"),
-        ("workflows.delete_workflow"),
-        ("workflows.get_workflow"),
-        ("workflows.list_workflows"),
-        ("workflows.run_workflow"),
-        ("workflows.update_workflow"),
     ],
 )
 def test_endpoint_uses_correct_url(monkeypatch, sdk_endpoint_name):
@@ -174,25 +155,6 @@ def test_endpoint_uses_correct_url(monkeypatch, sdk_endpoint_name):
     "sdk_endpoint_name",
     [
         ("general.partition_async"),
-        ("destinations.create_destination_async"),
-        ("destinations.delete_destination_async"),
-        ("destinations.get_destination_async"),
-        ("destinations.list_destinations_async"),
-        ("destinations.update_destination_async"),
-        ("jobs.cancel_job_async"),
-        ("jobs.get_job_async"),
-        ("jobs.list_jobs_async"),
-        ("sources.create_source_async"),
-        ("sources.delete_source_async"),
-        ("sources.get_source_async"),
-        ("sources.list_sources_async"),
-        ("sources.update_source_async"),
-        ("workflows.create_workflow_async"),
-        ("workflows.delete_workflow_async"),
-        ("workflows.get_workflow_async"),
-        ("workflows.list_workflows_async"),
-        ("workflows.run_workflow_async"),
-        ("workflows.update_workflow_async"),
     ],
 )
 async def test_async_endpoint_uses_correct_url(monkeypatch, sdk_endpoint_name):

src/unstructured_client/destinations.py

@@ -4,7 +4,6 @@
 from typing import Any, List, Mapping, Optional, Union, cast
 from unstructured_client import utils
 from unstructured_client._hooks import HookContext
-from unstructured_client._hooks.custom.clean_server_url_hook import choose_server_url
 from unstructured_client.models import errors, operations, shared
 from unstructured_client.types import BaseModel, OptionalNullable, UNSET
 
@@ -22,7 +21,9 @@ def create_destination(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.CreateDestinationResponse:
-        r"""Create Destination
+        r"""Create destination connector
+
+        Create a new destination connector using the provided configuration and name.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -35,15 +36,12 @@ def create_destination(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.CREATE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.CREATE_DESTINATION_SERVERS[
                 operations.CREATE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.CreateDestinationRequest)
@@ -143,7 +141,9 @@ async def create_destination_async(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.CreateDestinationResponse:
-        r"""Create Destination
+        r"""Create destination connector
+
+        Create a new destination connector using the provided configuration and name.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -156,15 +156,12 @@ async def create_destination_async(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.CREATE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.CREATE_DESTINATION_SERVERS[
                 operations.CREATE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.CreateDestinationRequest)
@@ -264,7 +261,9 @@ def delete_destination(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.DeleteDestinationResponse:
-        r"""Delete Destination
+        r"""Delete destination connector
+
+        Delete a specific destination connector by its ID.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -277,15 +276,12 @@ def delete_destination(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.DELETE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.DELETE_DESTINATION_SERVERS[
                 operations.DELETE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.DeleteDestinationRequest)
@@ -376,7 +372,9 @@ async def delete_destination_async(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.DeleteDestinationResponse:
-        r"""Delete Destination
+        r"""Delete destination connector
+
+        Delete a specific destination connector by its ID.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -389,15 +387,12 @@ async def delete_destination_async(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.DELETE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.DELETE_DESTINATION_SERVERS[
                 operations.DELETE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.DeleteDestinationRequest)
@@ -487,7 +482,9 @@ def get_destination(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.GetDestinationResponse:
-        r"""Get Destination
+        r"""Get destination connector
+
+        Retrieve detailed information for a specific destination connector by its ID.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -500,15 +497,12 @@ def get_destination(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.GET_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.GET_DESTINATION_SERVERS[
                 operations.GET_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.GetDestinationRequest)
@@ -600,7 +594,9 @@ async def get_destination_async(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.GetDestinationResponse:
-        r"""Get Destination
+        r"""Get destination connector
+
+        Retrieve detailed information for a specific destination connector by its ID.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -613,15 +609,12 @@ async def get_destination_async(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.GET_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.GET_DESTINATION_SERVERS[
                 operations.GET_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.GetDestinationRequest)
@@ -714,7 +707,9 @@ def list_destinations(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.ListDestinationsResponse:
-        r"""List Destinations
+        r"""List destination connectors
+
+        Retrieve a list of available destination connectors.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -727,15 +722,12 @@ def list_destinations(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.LIST_DESTINATIONS_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.LIST_DESTINATIONS_SERVERS[
                 operations.LIST_DESTINATIONS_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.ListDestinationsRequest)
@@ -829,7 +821,9 @@ async def list_destinations_async(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.ListDestinationsResponse:
-        r"""List Destinations
+        r"""List destination connectors
+
+        Retrieve a list of available destination connectors.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -842,15 +836,12 @@ async def list_destinations_async(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.LIST_DESTINATIONS_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.LIST_DESTINATIONS_SERVERS[
                 operations.LIST_DESTINATIONS_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.ListDestinationsRequest)
@@ -944,7 +935,9 @@ def update_destination(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.UpdateDestinationResponse:
-        r"""Update Destination
+        r"""Update destination connector
+
+        Update the configuration of an existing destination connector.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -957,15 +950,12 @@ def update_destination(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.UPDATE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.UPDATE_DESTINATION_SERVERS[
                 operations.UPDATE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.UpdateDestinationRequest)
@@ -1065,7 +1055,9 @@ async def update_destination_async(
         timeout_ms: Optional[int] = None,
         http_headers: Optional[Mapping[str, str]] = None,
     ) -> operations.UpdateDestinationResponse:
-        r"""Update Destination
+        r"""Update destination connector
+
+        Update the configuration of an existing destination connector.
 
         :param request: The request object to send.
         :param retries: Override the default retry configuration for this method
@@ -1078,15 +1070,12 @@ async def update_destination_async(
         if timeout_ms is None:
             timeout_ms = self.sdk_configuration.timeout_ms
 
-        client_url, *_ = self.sdk_configuration.get_server_details()
-
-        base_url = choose_server_url(
-            endpoint_url=server_url,
-            client_url=client_url,
-            default_endpoint_url=operations.UPDATE_DESTINATION_SERVERS[
+        if server_url is not None:
+            base_url = server_url
+        else:
+            base_url = operations.UPDATE_DESTINATION_SERVERS[
                 operations.UPDATE_DESTINATION_SERVER_PLATFORM_API
             ]
-        )
 
         if not isinstance(request, BaseModel):
             request = utils.unmarshal(request, operations.UpdateDestinationRequest)