From 4f514ec60eda0ad2fa38b9cf3d00aff39c68f4a2 Mon Sep 17 00:00:00 2001 From: Clif Houck Date: Tue, 25 Jul 2023 08:40:16 -0500 Subject: [PATCH] Fix ArmadaOperator use of job service channel arguments --- third_party/airflow/armada/operators/armada.py | 1 + 1 file changed, 1 insertion(+) diff --git a/third_party/airflow/armada/operators/armada.py b/third_party/airflow/armada/operators/armada.py index bb8b1d70fb0..33475651275 100644 --- 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