@@ -88,3 +88,30 @@ def test_upsert_audit_table_with_duplicate_message_id_raises_exception(self):
8888 expiry_timestamp = ravs_rsv_test_file .expires_at ,
8989 condition_expression = "attribute_not_exists(message_id)" ,
9090 )
91+
92+ def test_upsert_audit_table_with_duplicate_message_id_no_condition (self ):
93+ """Test that attempting to create an entry with a message_id that already exists causes no exception
94+ if the condition_expression is not set"""
95+ ravs_rsv_test_file = FileDetails ("RAVS" , "RSV" , "YGM41" , file_number = 1 )
96+
97+ upsert_audit_table (
98+ message_id = ravs_rsv_test_file .message_id ,
99+ file_key = ravs_rsv_test_file .file_key ,
100+ created_at_formatted_str = ravs_rsv_test_file .created_at_formatted_string ,
101+ queue_name = ravs_rsv_test_file .queue_name ,
102+ file_status = FileStatus .PROCESSING ,
103+ expiry_timestamp = ravs_rsv_test_file .expires_at ,
104+ )
105+
106+ assert_audit_table_entry (ravs_rsv_test_file , FileStatus .PROCESSING )
107+
108+ upsert_audit_table (
109+ message_id = ravs_rsv_test_file .message_id ,
110+ file_key = ravs_rsv_test_file .file_key ,
111+ created_at_formatted_str = ravs_rsv_test_file .created_at_formatted_string ,
112+ queue_name = ravs_rsv_test_file .queue_name ,
113+ file_status = FileStatus .PROCESSED ,
114+ expiry_timestamp = ravs_rsv_test_file .expires_at ,
115+ )
116+
117+ assert_audit_table_entry (ravs_rsv_test_file , FileStatus .PROCESSED )
0 commit comments