From 2cda5a79e65f4005dbf3c27a34c16590af344808 Mon Sep 17 00:00:00 2001 From: Arthi Jaganathan Date: Tue, 23 Jan 2024 20:43:43 +0800 Subject: [PATCH] Fixed EMR container operator import --- .../managed-airflow-mwaa/dags/example_emr_eks_new.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/schedulers/terraform/managed-airflow-mwaa/dags/example_emr_eks_new.py b/schedulers/terraform/managed-airflow-mwaa/dags/example_emr_eks_new.py index f48e5bdf3..86bd15c00 100644 --- a/schedulers/terraform/managed-airflow-mwaa/dags/example_emr_eks_new.py +++ b/schedulers/terraform/managed-airflow-mwaa/dags/example_emr_eks_new.py @@ -7,7 +7,7 @@ from airflow import DAG from airflow.hooks.base import BaseHook -from airflow.providers.amazon.aws.operators.emr_containers import EMRContainerOperator +from airflow.providers.amazon.aws.operators.emr import EmrContainerOperator from airflow.utils.dates import days_ago @@ -51,7 +51,7 @@ c = BaseHook.get_connection("emr_eks") cluster_args = c.extra_dejson # [START howto_operator_emr_eks_jobrun] - job_starter = EMRContainerOperator( + job_starter = EmrContainerOperator( task_id="start_job", virtual_cluster_id=cluster_args.get('virtual_cluster_id'), execution_role_arn=cluster_args.get('job_role_arn'),