Run black on codebase

E-CAM · May 22, 2019 · 6317d56 · 6317d56 · AdamWlodarczyk · May 22, 2019
1 parent 4b1c8fa
commit 6317d56
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/jobqueue_features/clusters.py b/jobqueue_features/clusters.py
@@ -555,16 +555,14 @@ def _update_script_nodes(self):  # type: () -> None
             dask_worker_module = "distributed.cli.dask_worker"
             command_template = command_template.replace(
                 "-m %s".format(dask_worker_module),
-                "-m %s".format(MPI_DASK_WRAPPER_MODULE)
+                "-m %s".format(MPI_DASK_WRAPPER_MODULE),
             )
             # The first part of the string is the python executable to use for the
             # worker
-            [python, arguments] = command_template.split(' ', 1)
+            [python, arguments] = command_template.split(" ", 1)
             # Wrap the launch command with our mpi wrapper
             command_template = mpi_wrap(
-                python,
-                exec_args=arguments,
-                return_wrapped_command=True
+                python, exec_args=arguments, return_wrapped_command=True
             )
             self.warnings.append(
                 "Replaced command template\n\t%s\nwith\n\t%s\nin jobscript".format(

diff --git a/jobqueue_features/mpi_dask_worker.py b/jobqueue_features/mpi_dask_worker.py
@@ -13,6 +13,7 @@
 
 MPI_DASK_WRAPPER_MODULE = "jobqueue_features.mpi_wrapper.mpi_dask_worker"
 
+
 def prepare_for_mpi_tasks(root=0, comm=None):
     if comm is None:
         from mpi4py import MPI