Remove non-existent extension call

Author: andystaples

azure-functions-durable/azure/durable_functions/client.py

@@ -5,12 +5,11 @@
 
 from datetime import timedelta
 import azure.functions as func
-from urllib.parse import urlparse, urljoin, quote
+from urllib.parse import urlparse, quote
 
 from durabletask.client import TaskHubGrpcClient
 from .internal.azurefunctions_grpc_interceptor import AzureFunctionsDefaultClientInterceptorImpl
 from .http import HttpManagementPayload
-import requests
 
 
 # Client class used for Durable Functions
@@ -44,10 +43,6 @@ def __init__(self, client_as_string: str):
             json.JSONDecodeError: If the provided string is not valid JSON.
         """
         self._parse_client_configuration(client_as_string)
-        if not self.httpBaseUrl:
-            # This happens when the extension has not been configured for gRPC yet. For some reason, instead of
-            # the client returning with null rpcBaseUrl and httpBaseUrl, it returns rpcBaseUrl with the http url.
-            self.configure_extension_for_grpc()
 
         interceptors = [AzureFunctionsDefaultClientInterceptorImpl(self.taskHubName, self.requiredQueryStringParameters)]
 
@@ -82,31 +77,6 @@ def _parse_client_configuration(self, client_as_string: str) -> None:
         # TODO: convert the string value back to timedelta - annoying regex?
         self.grpcHttpClientTimeout = client.get("grpcHttpClientTimeout", timedelta(seconds=30))
 
-    def configure_extension_for_grpc(self) -> None:
-        """Configures the Durable Functions extension for gRPC communication.
-
-        Makes an HTTP request to the extension's management endpoint to enable gRPC.
-        """
-
-        # Make an HTTP request to the extension to configure gRPC
-        configure_base_url = self.httpBaseUrl
-        if not configure_base_url:
-            # For some reason, in the "bad" case when rpc has not been configured, the httpBaseUrl is empty and sent in rpcBaseUrl
-            configure_base_url = self.rpcBaseUrl
-        # configure_base_url = urlparse(configure_base_url)
-        # url = f"{configure_base_url.scheme}://{configure_base_url.netloc}/management/configureGrpc"
-        url = urljoin(configure_base_url, "management/configureGrpc")
-        params = {
-            "taskHubName": self.taskHubName,
-            "connectionName": self.connectionName
-        }
-        response = requests.get(url, params=params)
-        if response.status_code != 200:
-            raise Exception(f"Failed to configure gRPC for Durable Functions extension. Status code: {response.status_code}, Response: {response.text}")
-
-        # Parse the response to update client configuration - it's double-encoded so we need to load it twice
-        self._parse_client_configuration(json.loads(response.text))
-
     def create_check_status_response(self, request: func.HttpRequest, instance_id: str) -> func.HttpResponse:
         """Creates an HTTP response for checking the status of a Durable Function instance.
 

azure-functions-durable/pyproject.toml

@@ -29,8 +29,7 @@ readme = "README.md"
 dependencies = [
     "durabletask>=1.2.0dev0",
     "azure-identity>=1.19.0",
-    "azure-functions>=1.25.0b3.dev1",
-    "requests>=2.31.0"
+    "azure-functions>=1.25.0b3.dev1"
 ]
 
 [project.urls]