fix

terraform-modules · Apr 28, 2023 · cfa4f79 · cfa4f79
1 parent 6ca736a
commit cfa4f79
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/code/ddns-lambda.py b/code/ddns-lambda.py
@@ -3310,9 +3310,9 @@ def discover_emr_cluster(tags):
 
     LOGGER.info(f"discover_emr tags {tags}")
     cluster_tuple = namedtuple('EMRCluster', ['is_cluster', 'is_master', 'cluster_id'])
-    cluster_id = tags.get('aws:elasticmapreduce:job-flow-id', '')
+    cluster_id = tags.get('emr:elasticmapreduce:job-flow-id', '')
     LOGGER.info(f"discover_emr cluster_id {cluster_id}")
-    is_master = tags.get('aws:elasticmapreduce:instance-group-role', '') == 'MASTER'
+    is_master = tags.get('emr:elasticmapreduce:instance-group-role', '') == 'MASTER'
     LOGGER.info(f"discover_emr is_master {is_master}")
     is_cluster = cluster_id != ''
     LOGGER.info(f"discover_emr is_cluster {is_cluster}")