From: Hoai-Thu Vuong Date: Thu, 23 Oct 2025 03:47:50 +0000 (+0700) Subject: squid: rgw-testing: fix unexpected keyword argument 'expected_sizes' for kafka test X-Git-Tag: testing/wip-jcollin-testing-20251203.125108-squid~10^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=a2253e186a2f8094f8d75006030b644bad94c6ae;p=ceph-ci.git squid: rgw-testing: fix unexpected keyword argument 'expected_sizes' for kafka test Signed-off-by: Hoai-Thu Vuong --- diff --git a/src/test/rgw/bucket_notification/test_bn.py b/src/test/rgw/bucket_notification/test_bn.py index b9c7c5d6f35..37f5b4b6cba 100644 --- a/src/test/rgw/bucket_notification/test_bn.py +++ b/src/test/rgw/bucket_notification/test_bn.py @@ -445,11 +445,15 @@ class KafkaReceiver(object): self.topic = topic self.stop = False - def verify_s3_events(self, keys, exact_match=False, deletions=False, etags=[]): + def verify_s3_events(self, keys, exact_match=False, deletions=False, etags=[], expected_sizes={}): """verify stored s3 records agains a list of keys""" - verify_s3_records_by_elements(self.events, keys, exact_match=exact_match, deletions=deletions, etags=etags) + verify_s3_records_by_elements(self.events, keys, exact_match=exact_match, deletions=deletions, etags=etags, expected_sizes=expected_sizes) self.events = [] + def close(self, task): + stop_kafka_receiver(self, task) + + def kafka_receiver_thread_runner(receiver): """main thread function for the kafka receiver""" try: @@ -1432,7 +1436,7 @@ def notification_push(endpoint_type, conn, account=None, cloudevents=False, kafk # start amqp receiver task, receiver = create_kafka_receiver_thread(topic_name, kafka_brokers=kafka_brokers) task.start() - endpoint_address = 'kafka://' + kafka_server + endpoint_address = 'kafka://' + kafka_server + ':9092' # without acks from broker endpoint_args = 'push-endpoint='+endpoint_address+'&kafka-ack-level=broker' if kafka_brokers is not None: