remove validate grpc key prefix

Signed-off-by: Filinto Duran <1373693+filintod@users.noreply.github.com>

Author: filintod

durabletask/aio/internal/shared.py

@@ -11,7 +11,6 @@
     INSECURE_PROTOCOLS,
     SECURE_PROTOCOLS,
     get_default_host_address,
-    validate_grpc_options,
 )
 
 ClientInterceptor = Union[
@@ -51,9 +50,6 @@ def get_grpc_aio_channel(
             host_address = host_address[len(protocol) :]
             break
 
-    if options is not None:
-        validate_grpc_options(options)
-
     if secure_channel:
         channel = grpc_aio.secure_channel(
             host_address, grpc.ssl_channel_credentials(), interceptors=interceptors, options=options

durabletask/worker.py

@@ -308,7 +308,10 @@ def create_fresh_connection():
             current_stub = None
             try:
                 current_channel = shared.get_grpc_channel(
-                    self._host_address, self._secure_channel, self._interceptors, options=self._channel_options
+                    self._host_address,
+                    self._secure_channel,
+                    self._interceptors,
+                    options=self._channel_options,
                 )
                 current_stub = stubs.TaskHubSidecarServiceStub(current_channel)
                 current_stub.Hello(empty_pb2.Empty())

tests/durabletask/test_orchestration_e2e.py

@@ -33,9 +33,7 @@ def empty_orchestrator(ctx: task.OrchestrationContext, _):
         w.start()
 
         # set a custom max send length option
-        c = client.TaskHubGrpcClient(
-            channel_options=channel_options
-        )
+        c = client.TaskHubGrpcClient(channel_options=channel_options)
         id = c.schedule_new_orchestration(empty_orchestrator)
         state = c.wait_for_orchestration_completion(id, timeout=30)
 

tests/durabletask/test_orchestration_e2e_async.py

@@ -62,13 +62,11 @@ def sequence(ctx: task.OrchestrationContext, start_val: int):
             numbers.append(current)
         return numbers
 
-    channel_options =[
-            ("grpc.max_send_message_length", 1024 * 1024),  # 1MB
-        ]
+    channel_options = [
+        ("grpc.max_send_message_length", 1024 * 1024),  # 1MB
+    ]
     # Start a worker, which will connect to the sidecar in a background thread
-    with worker.TaskHubGrpcWorker(
-        channel_options=channel_options
-    ) as w:
+    with worker.TaskHubGrpcWorker(channel_options=channel_options) as w:
         w.add_orchestrator(sequence)
         w.add_activity(plus_one)
         w.start()