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):