From d91a113dfa1a8f6cb9f52c3d272de16739d36f69 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Thu, 19 Dec 2024 17:44:07 +0000 Subject: [PATCH] Fix test --- .../apache_beam/io/external/xlang_kinesisio_it_test.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py b/sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py index 44e6b78f4e93..d37ce1f87fe3 100644 --- a/sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py +++ b/sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py @@ -115,9 +115,7 @@ def run_kinesis_write(self): aws_secret_key=self.aws_secret_key, region=self.aws_region, service_endpoint=self.aws_service_endpoint, - verify_certificate=(not self.use_localstack), - partition_key='1' - )) + partition_key='1')) def run_kinesis_read(self): records = [RECORD + str(i).encode() for i in range(NUM_RECORDS)] @@ -131,7 +129,6 @@ def run_kinesis_read(self): aws_secret_key=self.aws_secret_key, region=self.aws_region, service_endpoint=self.aws_service_endpoint, - verify_certificate=not self.use_localstack, max_num_records=NUM_RECORDS, max_read_time=MAX_READ_TIME, request_records_limit=REQUEST_RECORDS_LIMIT,