[beam] branch master updated: Remove save main session option in pubsubio_perf_test (#25822)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 8b3f2964344 Remove save main session option in pubsubio_perf_test 
(#25822)
8b3f2964344 is described below

commit 8b3f2964344cefa852fcdb04b87b9cbd06223ea3
Author: Yi Hu <ya...@google.com>
AuthorDate: Mon Mar 13 15:55:40 2023 -0400

    Remove save main session option in pubsubio_perf_test (#25822)
---
 sdks/python/apache_beam/io/gcp/pubsub_io_perf_test.py | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/sdks/python/apache_beam/io/gcp/pubsub_io_perf_test.py 
b/sdks/python/apache_beam/io/gcp/pubsub_io_perf_test.py
index a91b07018c8..aece17a1eaf 100644
--- a/sdks/python/apache_beam/io/gcp/pubsub_io_perf_test.py
+++ b/sdks/python/apache_beam/io/gcp/pubsub_io_perf_test.py
@@ -53,7 +53,6 @@ from apache_beam.io import Read
 from apache_beam.io import ReadFromPubSub
 from apache_beam.io.gcp.tests.pubsub_matcher import PubSubMessageMatcher
 from apache_beam.options.pipeline_options import PipelineOptions
-from apache_beam.options.pipeline_options import SetupOptions
 from apache_beam.options.pipeline_options import StandardOptions
 from apache_beam.testing.load_tests.load_test import LoadTest
 from apache_beam.testing.load_tests.load_test_metrics_utils import MeasureTime
@@ -138,7 +137,6 @@ class PubsubWritePerfTest(PubsubIOPerfTest):
 
   def _setup_pipeline(self):
     options = PipelineOptions(self.pipeline.get_full_options_as_args())
-    options.view_as(SetupOptions).save_main_session = True
     options.view_as(StandardOptions).streaming = True
     self.pipeline = TestPipeline(options=options)
 
@@ -201,7 +199,6 @@ class PubsubReadPerfTest(PubsubIOPerfTest):
     extra_opts = {
         'on_success_matcher': all_of(pubsub_msg_verifier),
         'streaming': True,
-        'save_main_session': True
     }
     args = self.pipeline.get_full_options_as_args(**extra_opts)
     self.pipeline = TestPipeline(options=PipelineOptions(args))