This is an automated email from the ASF dual-hosted git repository.
joshfell 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 7bd998e2ec fix(providers/amazon): remove event['message'] call in
EmrContainerOperator.execute_complete|as the key message no longer exists
(#36417)
7bd998e2ec is described below
commit 7bd998e2ec34ade8b4b360690c10f527c209452b
Author: Wei Lee <[email protected]>
AuthorDate: Tue Dec 26 08:09:38 2023 +0530
fix(providers/amazon): remove event['message'] call in
EmrContainerOperator.execute_complete|as the key message no longer exists
(#36417)
---
airflow/providers/amazon/aws/operators/emr.py | 1 -
1 file changed, 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/operators/emr.py
b/airflow/providers/amazon/aws/operators/emr.py
index 1f0b247b75..2a042cc784 100644
--- a/airflow/providers/amazon/aws/operators/emr.py
+++ b/airflow/providers/amazon/aws/operators/emr.py
@@ -623,7 +623,6 @@ class EmrContainerOperator(BaseOperator):
if event["status"] != "success":
raise AirflowException(f"Error while running job: {event}")
- self.log.info("%s", event["message"])
return event["job_id"]
def on_kill(self) -> None:
