From 9b8b2a940e79a55470ebb44f073600794189d35f Mon Sep 17 00:00:00 2001 From: hussein-awala Date: Mon, 27 Nov 2023 17:45:42 +0200 Subject: [PATCH] Stop getting message from event after migrating EmrContainerTrigger to AwsBaseWaiterTrigger --- airflow/providers/amazon/aws/sensors/emr.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/amazon/aws/sensors/emr.py b/airflow/providers/amazon/aws/sensors/emr.py index c184c28f1aa44..76bce335d2448 100644 --- a/airflow/providers/amazon/aws/sensors/emr.py +++ b/airflow/providers/amazon/aws/sensors/emr.py @@ -343,7 +343,7 @@ def execute_complete(self, context, event=None): raise AirflowSkipException(message) raise AirflowException(message) else: - self.log.info(event["message"]) + self.log.info("Job completed.") class EmrNotebookExecutionSensor(EmrBaseSensor):