Update datadog_lambda/dsm.py

michael-zhao459 · purple4reina · web-flow · commit d079ba65968d · 2025-06-03T13:05:10.000-04:00
Co-authored-by: Rey Abolofia &lt;purple4reina@gmail.com&gt;
diff --git a/datadog_lambda/dsm.py b/datadog_lambda/dsm.py
@@ -30,7 +30,7 @@ def _dsm_set_sqs_context(event):
 
             ctx = DsmPathwayCodec.decode(contextjson, processor())
             ctx.set_checkpoint(
-                ["direction:in", "topic:" + queue_arn, "type:sqs"],
+                ["direction:in", f"topic:{queue_arn}, "type:sqs"],
                 payload_size=payload_size,
             )
         except Exception as e:

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ def _dsm_set_sqs_context(event):`
`30`	`30`
`31`	`31`	`ctx = DsmPathwayCodec.decode(contextjson, processor())`
`32`	`32`	`ctx.set_checkpoint(`
`33`		`- ["direction:in", "topic:" + queue_arn, "type:sqs"],`
	`33`	`+ ["direction:in", f"topic:{queue_arn}, "type:sqs"],`
`34`	`34`	`payload_size=payload_size,`
`35`	`35`	`)`
`36`	`36`	`except Exception as e:`