To support extra delimiters for SF execution_arn

DataDog · Oct 27, 2023 · e922e9e · e922e9e
1 parent 4bf27da
commit e922e9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/aws/logs_monitoring/parsing.py b/aws/logs_monitoring/parsing.py
@@ -539,9 +539,9 @@ def awslogs_handler(event, context, metadata):
             message = json.loads(logs["logEvents"][0]["message"])
             if message.get("execution_arn") is not None:
                 execution_arn = message["execution_arn"]
-                arn_tokens = execution_arn.split(":")
+                arn_tokens = re.split(r"[:/\\]", execution_arn)
                 arn_tokens[5] = "stateMachine"
-                metadata[DD_HOST] = ":".join(arn_tokens[:-1])
+                metadata[DD_HOST] = ":".join(arn_tokens[:7])
                 state_machine_arn = ":".join(arn_tokens[:7])
         except Exception as e:
             logger.debug(