Skip to content

Commit

Permalink
revert set start method
Browse files Browse the repository at this point in the history
  • Loading branch information
amofakhar committed Oct 31, 2024
1 parent 10cea64 commit 6c0f428
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 8 deletions.
7 changes: 0 additions & 7 deletions pipelinewise/cli/multiprocess.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
1 change: 0 additions & 1 deletion pipelinewise/cli/pipelinewise.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down

0 comments on commit 6c0f428

Please sign in to comment.