@@ -3787,7 +3787,7 @@ def test_ps_s3_persistent_multiple_endpoints():
37873787
37883788 wait_for_queue_to_drain (topic_name + '_1' )
37893789
3790- http_server .verify_s3_events (keys , exact_match = False , deletions = False )
3790+ http_server .verify_s3_events (keys , exact_match = True , deletions = False )
37913791
37923792 # delete objects from the bucket
37933793 client_threads = []
@@ -3800,7 +3800,7 @@ def test_ps_s3_persistent_multiple_endpoints():
38003800
38013801 wait_for_queue_to_drain (topic_name + '_1' )
38023802
3803- http_server .verify_s3_events (keys , exact_match = False , deletions = True )
3803+ http_server .verify_s3_events (keys , exact_match = True , deletions = True )
38043804
38053805 # cleanup
38063806 s3_notification_conf1 .del_config ()
@@ -4094,7 +4094,7 @@ def test_ps_s3_topic_update():
40944094 #zone_bucket_checkpoint(ps_zone.zone, master_zone.zone, bucket_name)
40954095 keys = list (bucket .list ())
40964096 # TODO: use exact match
4097- receiver .verify_s3_events (keys , exact_match = False )
4097+ receiver .verify_s3_events (keys , exact_match = True )
40984098 # update the same topic with new endpoint
40994099 #topic_conf = PSTopic(ps_zone.conn, topic_name,endpoint='http://'+ hostname + ':' + str(port))
41004100 topic_conf = PSTopicS3 (conn , topic_name , endpoint_args = 'http://' + hostname + ':' + str (port ))
@@ -4752,6 +4752,7 @@ def test_persistent_ps_s3_data_path_v2_migration():
47524752 wait_for_queue_to_drain (topic_name )
47534753 # verify events
47544754 keys = list (bucket .list ())
4755+ # exact match is false because the notifications are persistent.
47554756 http_server .verify_s3_events (keys , exact_match = False )
47564757
47574758 except Exception as e :
@@ -4831,7 +4832,7 @@ def test_ps_s3_data_path_v2_migration():
48314832 try :
48324833 # verify events
48334834 keys = list (bucket .list ())
4834- http_server .verify_s3_events (keys , exact_match = False )
4835+ http_server .verify_s3_events (keys , exact_match = True )
48354836
48364837 # create topic to poll on
48374838 topic_name_1 = topic_name + '_1'
0 commit comments