Fixing grpc calls

Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>

Author: RyanLettieri

durabletask/client.py

@@ -113,7 +113,6 @@ def __init__(self, *,
 
         channel = shared.get_grpc_channel(
             host_address=host_address,
-            metadata=metadata,
             secure_channel=secure_channel,
             interceptors=self._interceptors
         )

durabletask/worker.py

@@ -131,7 +131,7 @@ def add_activity(self, fn: task.Activity) -> str:
 
     def start(self):
         """Starts the worker on a background thread and begins listening for work items."""
-        channel = shared.get_grpc_channel(self._host_address, self._metadata, self._secure_channel, self._interceptors)
+        channel = shared.get_grpc_channel(self._host_address, self._secure_channel, self._interceptors)
         stub = stubs.TaskHubSidecarServiceStub(channel)
 
         if self._is_running:

examples/dts/dts_activity_sequence.py

@@ -1,66 +1,66 @@
-"""End-to-end sample that demonstrates how to configure an orchestrator
-that calls an activity function in a sequence and prints the outputs."""
-import os
-from durabletask import task
-from durabletask.azuremanaged.worker import DurableTaskSchedulerWorker
-from durabletask.azuremanaged.client import DurableTaskSchedulerClient, OrchestrationStatus
-from azure.identity import DefaultAzureCredential
-
-def hello(ctx: task.ActivityContext, name: str) -> str:
-    """Activity function that returns a greeting"""
-    return f'Hello {name}!'
-
-
-def sequence(ctx: task.OrchestrationContext, _):
-    """Orchestrator function that calls the 'hello' activity function in a sequence"""
-    # call "hello" activity function in a sequence
-    result1 = yield ctx.call_activity(hello, input='Tokyo')
-    result2 = yield ctx.call_activity(hello, input='Seattle')
-    result3 = yield ctx.call_activity(hello, input='London')
-
-    # return an array of results
-    return [result1, result2, result3]
-
-
-# Read the environment variable
-taskhub_name = os.getenv("TASKHUB")
-
-# Check if the variable exists
-if taskhub_name:
-    print(f"The value of TASKHUB is: {taskhub_name}")
-else:
-    print("TASKHUB is not set. Please set the TASKHUB environment variable to the name of the taskhub you wish to use")
-    print("If you are using windows powershell, run the following: $env:TASKHUB=\"<taskhubname>\"")
-    print("If you are using bash, run the following: export TASKHUB=\"<taskhubname>\"")
-    exit()
-
-# Read the environment variable
-endpoint = os.getenv("ENDPOINT")
-
-# Check if the variable exists
-if endpoint:
-    print(f"The value of ENDPOINT is: {endpoint}")
-else:
-    print("ENDPOINT is not set. Please set the ENDPOINT environment variable to the endpoint of the scheduler")
-    print("If you are using windows powershell, run the following: $env:ENDPOINT=\"<schedulerEndpoint>\"")
-    print("If you are using bash, run the following: export ENDPOINT=\"<schedulerEndpoint>\"")
-    exit()
-
-credential = DefaultAzureCredential()
-
-# configure and start the worker
-with DurableTaskSchedulerWorker(host_address=endpoint, secure_channel=True,
-                                taskhub=taskhub_name, token_credential=credential) as w:
-    w.add_orchestrator(sequence)
-    w.add_activity(hello)
-    w.start()
-
-    # Construct the client and run the orchestrations
-    c = DurableTaskSchedulerClient(host_address=endpoint, secure_channel=True,
-                                   taskhub=taskhub_name, token_credential=credential)
-    instance_id = c.schedule_new_orchestration(sequence)
-    state = c.wait_for_orchestration_completion(instance_id, timeout=60)
-    if state and state.runtime_status == OrchestrationStatus.COMPLETED:
-        print(f'Orchestration completed! Result: {state.serialized_output}')
-    elif state:
-        print(f'Orchestration failed: {state.failure_details}')
+"""End-to-end sample that demonstrates how to configure an orchestrator
+that calls an activity function in a sequence and prints the outputs."""
+import os
+from durabletask import task
+from durabletask.azuremanaged.worker import DurableTaskSchedulerWorker
+from durabletask.azuremanaged.client import DurableTaskSchedulerClient, OrchestrationStatus
+from azure.identity import DefaultAzureCredential
+
+def hello(ctx: task.ActivityContext, name: str) -> str:
+    """Activity function that returns a greeting"""
+    return f'Hello {name}!'
+
+
+def sequence(ctx: task.OrchestrationContext, _):
+    """Orchestrator function that calls the 'hello' activity function in a sequence"""
+    # call "hello" activity function in a sequence
+    result1 = yield ctx.call_activity(hello, input='Tokyo')
+    result2 = yield ctx.call_activity(hello, input='Seattle')
+    result3 = yield ctx.call_activity(hello, input='London')
+
+    # return an array of results
+    return [result1, result2, result3]
+
+
+# Read the environment variable
+taskhub_name = os.getenv("TASKHUB")
+
+# Check if the variable exists
+if taskhub_name:
+    print(f"The value of TASKHUB is: {taskhub_name}")
+else:
+    print("TASKHUB is not set. Please set the TASKHUB environment variable to the name of the taskhub you wish to use")
+    print("If you are using windows powershell, run the following: $env:TASKHUB=\"<taskhubname>\"")
+    print("If you are using bash, run the following: export TASKHUB=\"<taskhubname>\"")
+    exit()
+
+# Read the environment variable
+endpoint = os.getenv("ENDPOINT")
+
+# Check if the variable exists
+if endpoint:
+    print(f"The value of ENDPOINT is: {endpoint}")
+else:
+    print("ENDPOINT is not set. Please set the ENDPOINT environment variable to the endpoint of the scheduler")
+    print("If you are using windows powershell, run the following: $env:ENDPOINT=\"<schedulerEndpoint>\"")
+    print("If you are using bash, run the following: export ENDPOINT=\"<schedulerEndpoint>\"")
+    exit()
+
+credential = DefaultAzureCredential()
+
+# configure and start the worker
+with DurableTaskSchedulerWorker(host_address=endpoint, secure_channel=True,
+                                taskhub=taskhub_name, token_credential=credential) as w:
+    w.add_orchestrator(sequence)
+    w.add_activity(hello)
+    w.start()
+
+    # Construct the client and run the orchestrations
+    c = DurableTaskSchedulerClient(host_address=endpoint, secure_channel=True,
+                                   taskhub=taskhub_name, token_credential=credential)
+    instance_id = c.schedule_new_orchestration(sequence)
+    state = c.wait_for_orchestration_completion(instance_id, timeout=60)
+    if state and state.runtime_status == OrchestrationStatus.COMPLETED:
+        print(f'Orchestration completed! Result: {state.serialized_output}')
+    elif state:
+        print(f'Orchestration failed: {state.failure_details}')