AirflowOperator - Capitalize armada in log messages to Armada (#3909)

armadaproject · Sep 5, 2024 · 9815369 · 9815369
1 parent 0d5415e
commit 9815369
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/third_party/airflow/armada/operators/armada.py b/third_party/airflow/armada/operators/armada.py
@@ -213,7 +213,7 @@ def on_kill(self) -> None:
         if self.job_context is not None:
             self.log.info(
                 f"on_kill called, "
-                f"cancelling armada job with job-id {self.job_context.job_id} in queue "
+                f"cancelling Armada job with job-id {self.job_context.job_id} in queue "
                 f"{self.job_context.armada_queue}"
             )
             self.hook.cancel_job(self.job_context)
@@ -264,7 +264,7 @@ def _reattach_or_submit_job(
         )
         if existing_run is not None:
             self.log.info(
-                "Attached to existing armada job "
+                "Attached to existing Armada job "
                 f"with job-id {existing_run['armada_job_id']}."
                 f" {self._trigger_tracking_message(existing_run['armada_job_id'])}"
             )
@@ -278,7 +278,7 @@ def _reattach_or_submit_job(
         # We haven't got a running job, submit a new one and persist state to xcom.
         ctx = self.hook.submit_job(self.armada_queue, job_set_id, job_request)
         tracking_msg = self._trigger_tracking_message(ctx.job_id)
-        self.log.info(f"Submitted job to armada with job-id {ctx.job_id}. {tracking_msg}")
+        self.log.info(f"Submitted job to Armada with job-id {ctx.job_id}. {tracking_msg}")
 
         ti.xcom_push(
             key=f"{ti.try_number}",