@@ -16,24 +16,20 @@ def setUp(self):
1616 self .mock_dsm_set_sqs_context = patcher .start ()
1717 self .addCleanup (patcher .stop )
1818
19- # Patch set_consume_checkpoint for testing DSM functionality
2019 patcher = patch ("ddtrace.data_streams.set_consume_checkpoint" )
2120 self .mock_set_consume_checkpoint = patcher .start ()
2221 self .addCleanup (patcher .stop )
2322
24- # Patch _get_dsm_context_from_lambda for testing DSM context extraction
2523 patcher = patch ("datadog_lambda.dsm._get_dsm_context_from_lambda" )
2624 self .mock_get_dsm_context_from_lambda = patcher .start ()
2725 self .addCleanup (patcher .stop )
2826
2927 def test_non_sqs_event_source_does_nothing (self ):
3028 """Test that non-SQS event sources don't trigger DSM context setting"""
3129 event = {}
32- # Use Unknown Event Source
3330 event_source = _EventSource (EventTypes .UNKNOWN )
3431 set_dsm_context (event , event_source )
3532
36- # DSM context should not be set for non-SQS events
3733 self .mock_dsm_set_sqs_context .assert_not_called ()
3834
3935 def test_sqs_event_with_no_records_does_nothing (self ):
@@ -46,7 +42,6 @@ def test_sqs_event_with_no_records_does_nothing(self):
4642
4743 for event in events_with_no_records :
4844 _dsm_set_sqs_context (event )
49- # Should not call set_consume_checkpoint for events without records
5045 self .mock_set_consume_checkpoint .assert_not_called ()
5146
5247 def test_sqs_event_triggers_dsm_sqs_context (self ):
0 commit comments