Skip to content

Commit d1bebf9

Browse files
needed queue name for consistent hash
1 parent d2fd3dc commit d1bebf9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

datadog_lambda/wrapper.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,13 +304,14 @@ def _before(self, event, context):
304304
def _dsm_set_sqs_context(record):
305305
try:
306306
queue_arn = record.get("eventSourceARN", "")
307+
queue_name = queue_arn.split(":")[-1]
307308

308309
contextjson = get_datastreams_context(record)
309310
payload_size = calculate_sqs_payload_size(record)
310311

311312
ctx = DsmPathwayCodec.decode(contextjson, processor())
312313
ctx.set_checkpoint(
313-
["direction:in", "queue:arn:" + queue_arn, "type:sqs"],
314+
["direction:in", "topic:" + queue_name, "type:sqs"],
314315
payload_size=payload_size,
315316
)
316317

0 commit comments

Comments
 (0)