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 a2cb789 commit d606a85Copy full SHA for d606a85
1 file changed
sdks/python/apache_beam/runners/portability/portable_runner_test.py
@@ -328,6 +328,22 @@ class PortableRunnerTestWithSubprocessesAndMultiWorkers(
328
PortableRunnerTestWithSubprocesses):
329
_use_subprocesses = True
330
331
+ @classmethod
332
+ def setUpClass(cls):
333
+ import os
334
+ cls._old_fork_support = os.environ.get('GRPC_ENABLE_FORK_SUPPORT')
335
+ os.environ['GRPC_ENABLE_FORK_SUPPORT'] = 'false'
336
+ super().setUpClass()
337
+
338
339
+ def tearDownClass(cls):
340
341
+ if cls._old_fork_support is None:
342
+ os.environ.pop('GRPC_ENABLE_FORK_SUPPORT', None)
343
+ else:
344
+ os.environ['GRPC_ENABLE_FORK_SUPPORT'] = cls._old_fork_support
345
+ super().tearDownClass()
346
347
def create_options(self):
348
options = super() \
349
.create_options()
0 commit comments