From cfa4f79e1e56cb5d33ba08e93856aec3fddaade1 Mon Sep 17 00:00:00 2001 From: badra001 Date: Thu, 27 Apr 2023 20:48:37 -0400 Subject: [PATCH] fix --- code/ddns-lambda.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/code/ddns-lambda.py b/code/ddns-lambda.py index 66921d1..3750702 100755 --- 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}")