From 6c0f4286772c62186a0a086fdecc63bb83a01574 Mon Sep 17 00:00:00 2001 From: Amir Mofakhar Date: Thu, 31 Oct 2024 15:02:38 +0000 Subject: [PATCH] revert set start method --- pipelinewise/cli/multiprocess.py | 7 ------- pipelinewise/cli/pipelinewise.py | 1 - 2 files changed, 8 deletions(-) diff --git a/pipelinewise/cli/multiprocess.py b/pipelinewise/cli/multiprocess.py index d8e6c55a9..88b674d96 100644 --- a/pipelinewise/cli/multiprocess.py +++ b/pipelinewise/cli/multiprocess.py @@ -28,10 +28,3 @@ def exception(self): if self._pconn.poll(): self._exception = self._pconn.recv() return self._exception - - @classmethod - def set_start_method_as_spawn(cls): - """ - set start method as spawn - """ - multiprocessing.set_start_method('spawn', force=True) diff --git a/pipelinewise/cli/pipelinewise.py b/pipelinewise/cli/pipelinewise.py index b2c95de18..4696c1330 100644 --- a/pipelinewise/cli/pipelinewise.py +++ b/pipelinewise/cli/pipelinewise.py @@ -1403,7 +1403,6 @@ def do_sync_tables(self, fastsync_stream_ids=None): self._reset_state_file_for_partial_sync(selected_tables) partial_sync_process = Process( target=self.sync_tables_partial_sync, args=(selected_tables['partial_sync'],)) - partial_sync_process.set_start_method_as_spawn() partial_sync_process.start() processes_list.append(partial_sync_process)