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}")