fix

michael-zhao459 · michael-zhao459 · commit 296c01557c55 · 2025-06-03T13:12:01.000-04:00
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", f"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", f"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:`