Fix ArmadaOperator use of job service channel arguments

armadaproject · Jul 25, 2023 · 4f514ec · 4f514ec
1 parent a0fad29
commit 4f514ec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/third_party/airflow/armada/operators/armada.py b/third_party/airflow/armada/operators/armada.py
@@ -88,6 +88,7 @@ def __init__(
         if "options" not in job_service_channel_args:
             job_service_channel_args["options"] = default_jobservice_channel_options
 
+        self.job_service_channel_args = GrpcChannelArguments(**job_service_channel_args)
         self.armada_queue = armada_queue
         self.job_request_items = job_request_items
         self.lookout_url_template = lookout_url_template