@@ -102,7 +102,7 @@ def _chunksize_to_kwargs(self, chunk_size, kwargs, label="chunk_size"):
102102
103103
104104class NoDaemonProcess (multiprocessing .Process ):
105- """Class that represents a non-daemon process"""
105+ """Class that represents a non-daemon process. """
106106
107107 # pylint: disable=dangerous-default-value
108108
@@ -111,17 +111,17 @@ def __init__(self, group=None, target=None, name=None, args=(), kwargs={}):
111111 super ().__init__ (group = None , target = target , name = name , args = args , kwargs = kwargs )
112112
113113 def _get_daemon (self ): # pylint: disable=no-self-use
114- """Get daemon flag"""
114+ """Get daemon flag. """
115115 return False # pragma: no cover
116116
117117 def _set_daemon (self , value ):
118- """Set daemon flag"""
118+ """Set daemon flag. """
119119
120120 daemon = property (_get_daemon , _set_daemon )
121121
122122
123123class NestedPool (Pool ): # pylint: disable=abstract-method
124- """Class that represents a MultiProcessing nested pool"""
124+ """Class that represents a MultiProcessing nested pool. """
125125
126126 Process = NoDaemonProcess
127127
@@ -146,7 +146,6 @@ class MultiprocessingFactory(ParallelFactory):
146146
147147 def __init__ (self , batch_size = None , chunk_size = None , processes = None , ** kwargs ):
148148 """Initialize multiprocessing factory."""
149-
150149 super ().__init__ (batch_size , chunk_size )
151150
152151 self .nb_processes = processes or os .cpu_count ()
@@ -280,7 +279,7 @@ def __init__(
280279 scheduler_file = None ,
281280 address = None ,
282281 dask_config = None ,
283- ** kwargs
282+ ** kwargs ,
284283 ):
285284 super ().__init__ (
286285 batch_size , chunk_size , scheduler_file = scheduler_file , address = address , ** kwargs
@@ -308,7 +307,6 @@ def _with_batches(self, *args, **kwargs):
308307
309308 def get_mapper (self , batch_size = None , chunk_size = None , ** kwargs ):
310309 """Get a Dask mapper."""
311-
312310 self ._chunksize_to_kwargs (chunk_size , kwargs , label = "chunksize" )
313311 if not kwargs .get ("chunksize" ):
314312 kwargs ["npartitions" ] = self .nb_processes or 1
0 commit comments