Skip to content
This repository has been archived by the owner on Jan 30, 2023. It is now read-only.

Commit

Permalink
30238: fix pycodestyle in map_reduce.py
Browse files Browse the repository at this point in the history
  • Loading branch information
seblabbe committed Jul 30, 2020
1 parent d180dc5 commit 41aaa0a
Showing 1 changed file with 14 additions and 7 deletions.
21 changes: 14 additions & 7 deletions src/sage/parallel/map_reduce.py
Original file line number Diff line number Diff line change
Expand Up @@ -936,12 +936,18 @@ def __init__(self,
if hasattr(forest, 'post_process'):
self.post_process = forest.post_process
else:
if roots is not None: self._roots = roots
if children is not None: self.children = children
if post_process is not None: self.post_process = post_process
if map_function is not None: self.map_function = map_function
if reduce_function is not None: self.reduce_function = reduce_function
if reduce_init is not None: self._reduce_init = reduce_init
if roots is not None:
self._roots = roots
if children is not None:
self.children = children
if post_process is not None:
self.post_process = post_process
if map_function is not None:
self.map_function = map_function
if reduce_function is not None:
self.reduce_function = reduce_function
if reduce_init is not None:
self._reduce_init = reduce_init
self._profile = None

@lazy_attribute
Expand Down Expand Up @@ -1151,7 +1157,8 @@ def start_workers(self):
logger.debug("Starting processes")
sys.stdout.flush()
sys.stderr.flush()
for w in self._workers: w.start()
for w in self._workers:
w.start()

def get_results(self, timeout=None):
r"""
Expand Down

0 comments on commit 41aaa0a

Please sign in to comment.