Fix test

apache · Dec 19, 2024 · d91a113 · d91a113
1 parent fb462b4
commit d91a113
Showing 1 changed file with 1 addition and 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
@@ -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,