Beuatified code

bob/pipelines/distributed/__init__.py

@@ -67,11 +67,13 @@ def dask_get_partition_size(cluster, n_objects, lower_bound=200):
         else n_objects
     )
 
+
 def get_local_parallel_client(parallel=None, processes=True):
     """Returns a local Dask client with the given parameters, see the dask documentation for details: https://docs.dask.org/en/latest/how-to/deploy-dask/single-distributed.html?highlight=localcluster#localcluster
 
     Parameters
     ----------
+
         parallel: int or None
             The number of workers (processes or threads) to use; if `None`, take as many processors as we have on the system
 
@@ -88,6 +90,6 @@ def get_local_parallel_client(parallel=None, processes=True):
     cluster = LocalCluster(
         processes=processes,
         n_workers=parallel if processes else 1,
-        threads_per_worker= 1 if processes else parallel,
+        threads_per_worker=1 if processes else parallel,
     )
     return Client(cluster)