Blacken after likely a black change.

dask_jobqueue/core.py

@@ -362,7 +362,7 @@ def _close_job(cls, job_id):
 
     @staticmethod
     def _call(cmd, **kwargs):
-        """ Call a command using subprocess.Popen.
+        """Call a command using subprocess.Popen.
 
         This centralizes calls out to the command line, providing consistent
         outputs, logging, and an opportunity to go asynchronous in the future.
@@ -590,7 +590,7 @@ def job_name(self):
         return self._dummy_job.job_name
 
     def scale(self, n=None, jobs=0, memory=None, cores=None):
-        """ Scale cluster to specified configurations.
+        """Scale cluster to specified configurations.
 
         Parameters
         ----------
@@ -612,7 +612,7 @@ def scale(self, n=None, jobs=0, memory=None, cores=None):
     def adapt(
         self, *args, minimum_jobs: int = None, maximum_jobs: int = None, **kwargs
     ):
-        """ Scale Dask cluster automatically based on scheduler activity.
+        """Scale Dask cluster automatically based on scheduler activity.
 
         Parameters
         ----------

dask_jobqueue/htcondor.py

@@ -95,8 +95,8 @@ def __init__(
             self.job_header_dict.update(self.job_extra)
 
     def env_lines_to_dict(self, env_lines):
-        """ Convert an array of export statements (what we get from env-extra
-        in the config) into a dict """
+        """Convert an array of export statements (what we get from env-extra
+        in the config) into a dict"""
         env_dict = {}
         for env_line in env_lines:
             split_env_line = shlex.split(env_line)

dask_jobqueue/lsf.py

@@ -113,7 +113,7 @@ async def _submit_job(self, script_filename):
 
 
 def lsf_format_bytes_ceil(n, lsf_units="mb"):
-    """ Format bytes as text
+    """Format bytes as text
 
     Convert bytes to megabytes which LSF requires.
 
@@ -135,9 +135,7 @@ def lsf_format_bytes_ceil(n, lsf_units="mb"):
 
 
 def lsf_detect_units():
-    """ Try to autodetect the unit scaling on an LSF system
-
-    """
+    """Try to autodetect the unit scaling on an LSF system"""
     # Search for automatically, Using docs from LSF 9.1.3 for search/defaults
     unit = "kb"  # Default fallback unit
     try:

dask_jobqueue/pbs.py

@@ -10,7 +10,7 @@
 
 
 def pbs_format_bytes_ceil(n):
-    """ Format bytes as text.
+    """Format bytes as text.
 
     PBS expects KiB, MiB or Gib, but names it KB, MB, GB whereas Dask makes the difference between KB and KiB.
 

dask_jobqueue/slurm.py

@@ -84,7 +84,7 @@ def __init__(
 
 
 def slurm_format_bytes_ceil(n):
-    """ Format bytes as text.
+    """Format bytes as text.
 
     SLURM expects KiB, MiB or Gib, but names it KB, MB, GB. SLURM does not handle Bytes, only starts at KB.
 

dask_jobqueue/tests/test_jobqueue_core.py

@@ -408,7 +408,7 @@ def test_wrong_parameter_error(Cluster):
     )
     with pytest.raises(ValueError, match=match):
         create_cluster_func(
-            Cluster, cores=1, memory="1GB", wrong_parameter="wrong_parameter_value",
+            Cluster, cores=1, memory="1GB", wrong_parameter="wrong_parameter_value"
         )