This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 0f5db49ec4 Stop getting message from event after migrating
`EmrContainerTrigger` to `AwsBaseWaiterTrigger` (#35892)
0f5db49ec4 is described below
commit 0f5db49ec41b12d68c51f4409aa45edf4aba6a94
Author: Hussein Awala <[email protected]>
AuthorDate: Mon Nov 27 18:47:05 2023 +0200
Stop getting message from event after migrating `EmrContainerTrigger` to
`AwsBaseWaiterTrigger` (#35892)
---
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 c184c28f1a..76bce335d2 100644
--- a/airflow/providers/amazon/aws/sensors/emr.py
+++ b/airflow/providers/amazon/aws/sensors/emr.py
@@ -343,7 +343,7 @@ class EmrContainerSensor(BaseSensorOperator):
raise AirflowSkipException(message)
raise AirflowException(message)
else:
- self.log.info(event["message"])
+ self.log.info("Job completed.")
class EmrNotebookExecutionSensor(EmrBaseSensor):
