fix tag prefix check for emr

terraform-modules · May 11, 2023 · 37ebb44 · 37ebb44
1 parent a2adb62
commit 37ebb44
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/code/ddns-lambda.py b/code/ddns-lambda.py
@@ -73,7 +73,7 @@
 LOGGER = logging.getLogger()
 account_id = None
 region = None
-VERSION = '2.0.2'
+VERSION = '2.0.3'
 
 # Read Env variables
 DEBUG_LOG_LEVEL = os.environ.get('DebugLogLevel', 'INFO')
@@ -3339,9 +3339,9 @@ def discover_emr_cluster(tags):
     """
 
     cluster_tuple = namedtuple('EMRCluster', ['is_cluster', 'is_master', 'cluster_id'])
-    cluster_id = tags.get('{EMR_TAG_PREFIX}:elasticmapreduce:job-flow-id', '')
+    cluster_id = tags.get(f'{EMR_TAG_PREFIX}:elasticmapreduce:job-flow-id', '')
     is_master = tags.get(
-        '{EMR_TAG_PREFIX}:elasticmapreduce:instance-group-role', '') == 'MASTER'
+        f'{EMR_TAG_PREFIX}:elasticmapreduce:instance-group-role', '') == 'MASTER'
     is_cluster = cluster_id != ''
 
     result = cluster_tuple(is_cluster, is_master, cluster_id)