This is an automated email from the ASF dual-hosted git repository.
onikolas 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 359dfb5446 Added config template field to
EmrServerlessStartJobOperator (#31746)
359dfb5446 is described below
commit 359dfb54469cb33b817d0e76641e2be09dc04d2d
Author: Maham Ali <[email protected]>
AuthorDate: Wed Jun 7 15:03:30 2023 -0700
Added config template field to EmrServerlessStartJobOperator (#31746)
* Added template_fields_renderers attribute, specified json for config and
configuration_overrides fields
---
airflow/providers/amazon/aws/operators/emr.py | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/airflow/providers/amazon/aws/operators/emr.py
b/airflow/providers/amazon/aws/operators/emr.py
index 1490775fe6..cf903b8ddc 100644
--- a/airflow/providers/amazon/aws/operators/emr.py
+++ b/airflow/providers/amazon/aws/operators/emr.py
@@ -963,11 +963,17 @@ class EmrServerlessStartJobOperator(BaseOperator):
template_fields: Sequence[str] = (
"application_id",
+ "config",
"execution_role_arn",
"job_driver",
"configuration_overrides",
)
+ template_fields_renderers = {
+ "config": "json",
+ "configuration_overrides": "json",
+ }
+
def __init__(
self,
application_id: str,
