@@ -2456,7 +2456,6 @@ def setUp(self):
24562456
24572457 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
24582458 def test_sqs_context_propagated_string_value (self , mock_dsm_set_checkpoint ):
2459- """Test SQS with valid String datadog context"""
24602459 dd_data = {"dd-pathway-ctx-base64" : "12345" }
24612460 dd_json_data = json .dumps (dd_data )
24622461
@@ -2482,7 +2481,6 @@ def test_sqs_context_propagated_string_value(self, mock_dsm_set_checkpoint):
24822481
24832482 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
24842483 def test_sqs_context_propagated_binary_value (self , mock_dsm_set_checkpoint ):
2485- """Test SQS with valid Binary datadog context"""
24862484 dd_data = {"dd-pathway-ctx-base64" : "12345" }
24872485 dd_json_data = json .dumps (dd_data )
24882486 encoded_data = base64 .b64encode (dd_json_data .encode ()).decode ()
@@ -2509,7 +2507,6 @@ def test_sqs_context_propagated_binary_value(self, mock_dsm_set_checkpoint):
25092507
25102508 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
25112509 def test_sqs_no_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2512- """Test SQS with no _datadog key set DSM checkpoint with None"""
25132510 event = {
25142511 "Records" : [
25152512 {
@@ -2530,7 +2527,6 @@ def test_sqs_no_datadog_message_attribute(self, mock_dsm_set_checkpoint):
25302527
25312528 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
25322529 def test_sqs_incorrect_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2533- """Test SQS with unsupported dataType set DSM checkpoint with None"""
25342530 event = {
25352531 "Records" : [
25362532 {
@@ -2556,7 +2552,6 @@ def test_sqs_incorrect_datadog_message_attribute(self, mock_dsm_set_checkpoint):
25562552
25572553 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
25582554 def test_sqs_empty_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2559- """Test SQS with empty datadog context set DSM checkpoint with None"""
25602555 event = {
25612556 "Records" : [
25622557 {
@@ -2575,14 +2570,12 @@ def test_sqs_empty_datadog_message_attribute(self, mock_dsm_set_checkpoint):
25752570 extract_context_from_sqs_or_sns_event_or_context (
25762571 event , self .lambda_context , parse_event_source (event )
25772572 )
2578-
25792573 mock_dsm_set_checkpoint .assert_called_once_with (
25802574 None , "sqs" , "arn:aws:sqs:us-east-1:123456789012:test-queue"
25812575 )
25822576
25832577 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
25842578 def test_sqs_no_DSM_context_in_message_attribute (self , mock_dsm_set_checkpoint ):
2585- """Test SQS with no DSM context in _datadog message attribute - carrier_get returns None"""
25862579 dd_data = {"NOT-DSM-KEY" : "12345" }
25872580 dd_json_data = json .dumps (dd_data )
25882581 event = {
@@ -2614,7 +2607,6 @@ def test_sqs_no_DSM_context_in_message_attribute(self, mock_dsm_set_checkpoint):
26142607 def test_sqs_invalid_datadog_message_attribute_raises_exception (
26152608 self , mock_dsm_set_checkpoint
26162609 ):
2617- """Test SQS when exception occurs due to invalid base64 - ctx_json=None"""
26182610 event = {
26192611 "Records" : [
26202612 {
@@ -2640,7 +2632,6 @@ def test_sqs_invalid_datadog_message_attribute_raises_exception(
26402632
26412633 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
26422634 def test_sqs_source_arn_not_found (self , mock_dsm_set_checkpoint ):
2643- """Test SQS with empty source ARN - arn parameter"""
26442635 event = {
26452636 "Records" : [
26462637 {
@@ -2672,7 +2663,6 @@ def test_sqs_data_streams_disabled(self):
26722663
26732664 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
26742665 def test_sns_context_propagated_string_value (self , mock_dsm_set_checkpoint ):
2675- """Test SNS with valid String datadog context"""
26762666 dd_data = {"dd-pathway-ctx-base64" : "12345" }
26772667 dd_json_data = json .dumps (dd_data )
26782668
@@ -2701,7 +2691,6 @@ def test_sns_context_propagated_string_value(self, mock_dsm_set_checkpoint):
27012691
27022692 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
27032693 def test_sns_context_propagated_binary_value (self , mock_dsm_set_checkpoint ):
2704- """Test SNS with valid Binary datadog context"""
27052694 dd_data = {"dd-pathway-ctx-base64" : "12345" }
27062695 dd_json_data = json .dumps (dd_data )
27072696 encoded_data = base64 .b64encode (dd_json_data .encode ()).decode ()
@@ -2731,7 +2720,6 @@ def test_sns_context_propagated_binary_value(self, mock_dsm_set_checkpoint):
27312720
27322721 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
27332722 def test_sns_no_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2734- """Test SNS with no _datadog key set DSM checkpoint with None"""
27352723 event = {
27362724 "Records" : [
27372725 {
@@ -2754,7 +2742,6 @@ def test_sns_no_datadog_message_attribute(self, mock_dsm_set_checkpoint):
27542742
27552743 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
27562744 def test_sns_incorrect_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2757- """Test SNS with unsupported dataType set DSM checkpoint with None"""
27582745 event = {
27592746 "Records" : [
27602747 {
@@ -2782,7 +2769,6 @@ def test_sns_incorrect_datadog_message_attribute(self, mock_dsm_set_checkpoint):
27822769
27832770 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
27842771 def test_sns_empty_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2785- """Test SNS with empty datadog context set DSM checkpoint with None"""
27862772 event = {
27872773 "Records" : [
27882774 {
@@ -2810,7 +2796,6 @@ def test_sns_empty_datadog_message_attribute(self, mock_dsm_set_checkpoint):
28102796
28112797 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
28122798 def test_sns_no_DSM_context_in_message_attribute (self , mock_dsm_set_checkpoint ):
2813- """Test SNS with no DSM context in _datadog message attribute - carrier_get returns None"""
28142799 dd_data = {"NOT-DSM-KEY" : "12345" }
28152800 dd_json_data = json .dumps (dd_data )
28162801
@@ -2846,7 +2831,6 @@ def test_sns_no_DSM_context_in_message_attribute(self, mock_dsm_set_checkpoint):
28462831 def test_sns_invalid_datadog_message_attribute_raises_exception (
28472832 self , mock_dsm_set_checkpoint
28482833 ):
2849- """Test SNS with invalid base64 raises exception and sets checkpoint with None"""
28502834 event = {
28512835 "Records" : [
28522836 {
@@ -2874,7 +2858,7 @@ def test_sns_invalid_datadog_message_attribute_raises_exception(
28742858
28752859 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
28762860 def test_sns_source_arn_not_found (self , mock_dsm_set_checkpoint ):
2877- """Test SNS with empty source ARN - arn parameter """
2861+ """Test SNS with empty source ARN"""
28782862 event = {
28792863 "Records" : [
28802864 {
@@ -2908,7 +2892,6 @@ def test_sns_data_streams_disabled(self):
29082892
29092893 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
29102894 def test_sns_to_sqs_context_propagated_string_value (self , mock_dsm_set_checkpoint ):
2911- """Test SNS->SQS with valid datadog context and SQS ARN"""
29122895 dd_data = {"dd-pathway-ctx-base64" : "12345" }
29132896 dd_json_data = json .dumps (dd_data )
29142897
@@ -2943,7 +2926,6 @@ def test_sns_to_sqs_context_propagated_string_value(self, mock_dsm_set_checkpoin
29432926
29442927 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
29452928 def test_sns_to_sqs_context_propagated_binary_value (self , mock_dsm_set_checkpoint ):
2946- """Test SNS->SQS with valid Binary datadog context"""
29472929 dd_data = {"dd-pathway-ctx-base64" : "12345" }
29482930 dd_json_data = json .dumps (dd_data )
29492931 encoded_data = base64 .b64encode (dd_json_data .encode ()).decode ()
@@ -2981,7 +2963,6 @@ def test_sns_to_sqs_context_propagated_binary_value(self, mock_dsm_set_checkpoin
29812963
29822964 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
29832965 def test_sns_to_sqs_no_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
2984- """Test SNS->SQS with no _datadog key set DSM checkpoint with None"""
29852966 sns_notification = {
29862967 "Type" : "Notification" ,
29872968 "TopicArn" : "arn:aws:sns:us-east-1:123456789012:test-topic" ,
@@ -3012,7 +2993,6 @@ def test_sns_to_sqs_no_datadog_message_attribute(self, mock_dsm_set_checkpoint):
30122993 def test_sns_to_sqs_incorrect_datadog_message_attribute (
30132994 self , mock_dsm_set_checkpoint
30142995 ):
3015- """Test SNS->SQS with unsupported dataType set DSM checkpoint with None"""
30162996 sns_notification = {
30172997 "Type" : "Notification" ,
30182998 "TopicArn" : "arn:aws:sns:us-east-1:123456789012:test-topic" ,
@@ -3043,7 +3023,6 @@ def test_sns_to_sqs_incorrect_datadog_message_attribute(
30433023
30443024 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
30453025 def test_sns_to_sqs_empty_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
3046- """Test SNS->SQS with empty datadog context set DSM checkpoint with None"""
30473026 sns_notification = {
30483027 "Type" : "Notification" ,
30493028 "TopicArn" : "arn:aws:sns:us-east-1:123456789012:test-topic" ,
@@ -3079,7 +3058,6 @@ def test_sns_to_sqs_empty_datadog_message_attribute(self, mock_dsm_set_checkpoin
30793058 def test_sns_to_sqs_no_DSM_context_in_message_attribute (
30803059 self , mock_dsm_set_checkpoint
30813060 ):
3082- """Test SNS->SQS with no DSM context, carrier_get returns None"""
30833061 dd_data = {"NOT-DSM-KEY" : "12345" }
30843062 dd_json_data = json .dumps (dd_data )
30853063 event = {
@@ -3111,7 +3089,6 @@ def test_sns_to_sqs_no_DSM_context_in_message_attribute(
31113089 def test_sns_to_sqs_invalid_datadog_message_attribute_raises_exception (
31123090 self , mock_dsm_set_checkpoint
31133091 ):
3114- """Test SNS->SQS with invalid base64 payload raises exception and sets checkpoint with None"""
31153092 sns_notification = {
31163093 "Type" : "Notification" ,
31173094 "TopicArn" : "arn:aws:sns:us-east-1:123456789012:test-topic" ,
@@ -3142,7 +3119,6 @@ def test_sns_to_sqs_invalid_datadog_message_attribute_raises_exception(
31423119
31433120 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
31443121 def test_sns_to_sqs_source_arn_not_found (self , mock_dsm_set_checkpoint ):
3145- """Test SNS->SQS with empty SQS ARN - arn parameter"""
31463122 sns_notification = {
31473123 "Type" : "Notification" ,
31483124 "TopicArn" : "arn:aws:sns:us-east-1:123456789012:test-topic" ,
@@ -3207,7 +3183,6 @@ def test_kinesis_context_propagated_binary_value(self, mock_dsm_set_checkpoint):
32073183
32083184 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
32093185 def test_kinesis_no_datadog_message_attribute (self , mock_dsm_set_checkpoint ):
3210- """Test Kinesis with no _datadog key set DSM checkpoint with None"""
32113186 kinesis_data = {"message" : "test" } # No _datadog key
32123187 kinesis_data_str = json .dumps (kinesis_data )
32133188 encoded_data = base64 .b64encode (kinesis_data_str .encode ()).decode ()
@@ -3231,7 +3206,6 @@ def test_kinesis_no_datadog_message_attribute(self, mock_dsm_set_checkpoint):
32313206 def test_kinesis_invalid_datadog_message_attribute_raises_exception (
32323207 self , mock_dsm_set_checkpoint
32333208 ):
3234- """Test Kinesis when exception occurs due to invalid base64 - ctx_json=None"""
32353209 event = {
32363210 "Records" : [
32373211 {
@@ -3249,7 +3223,6 @@ def test_kinesis_invalid_datadog_message_attribute_raises_exception(
32493223
32503224 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
32513225 def test_kinesis_no_DSM_context_in_message_attribute (self , mock_dsm_set_checkpoint ):
3252- """Test Kinesis with no DSM context - carrier_get returns None"""
32533226 dd_data = {"NOT-DSM-KEY" : "12345" }
32543227 kinesis_data = {"_datadog" : dd_data , "message" : "test" }
32553228 kinesis_data_str = json .dumps (kinesis_data )
@@ -3279,7 +3252,6 @@ def test_kinesis_no_DSM_context_in_message_attribute(self, mock_dsm_set_checkpoi
32793252
32803253 @patch ("datadog_lambda.tracing._dsm_set_checkpoint" )
32813254 def test_kinesis_source_arn_not_found (self , mock_dsm_set_checkpoint ):
3282- """Test Kinesis with empty source ARN - arn parameter"""
32833255 kinesis_data = {"message" : "test" }
32843256 kinesis_data_str = json .dumps (kinesis_data )
32853257 encoded_data = base64 .b64encode (kinesis_data_str .encode ()).decode ()
0 commit comments