We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 004c7ca commit 7972be0Copy full SHA for 7972be0
sdks/python/apache_beam/runners/portability/prism_runner.py
@@ -90,9 +90,9 @@ def default_environment(
90
return super().default_environment(options)
91
92
def default_job_server(self, options):
93
- debug_options = options.view_as(pipeline_options.DebugOptions)
94
- if not debug_options.lookup_experiment("disable_prism_server_singleton"):
95
- options = self.enforce_port_singleton(options)
+ #debug_options = options.view_as(pipeline_options.DebugOptions)
+ #if not debug_options.lookup_experiment("disable_prism_server_singleton"):
+ # options = self.enforce_port_singleton(options)
96
return job_server.StopOnExitJobServer(PrismJobServer(options))
97
98
def create_job_service_handle(self, job_service, options):
0 commit comments