[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

Diff for: benchmarks/benchmark_result.py

@@ -201,7 +201,6 @@ def add_no_delay_tasks_source(source, benchmark, number_of_cores):
         for result in benchmark['results']
         if not result.failed
     ]:
-
         dict_to_append_to['Duration in ms'].append(duration)
         dict_to_append_to['Number of tasks'].append(tasks_num)
         dict_to_append_to['Number of cores'].append(number_of_cores)

Diff for: benchmarks/profiling/profiling_code_runner.py

@@ -68,7 +68,6 @@ def get_tasks_to_execute(program_arguments):
 
 
 if __name__ == "__main__":
-
     print('profiling_code_runner_started')
     if '-s' not in sys.argv:
         n = int(sys.argv[1]) if len(sys.argv) > 1 else 16

Diff for: docs/source/examples/customresults.py

@@ -58,5 +58,5 @@ def sleep_here(count, t):
 
         # note that each job in a map always returns a list of length chunksize
         # even if chunksize == 1
-        for (count, t) in ar.get():
+        for count, t in ar.get():
             print("  item %i: slept for %.2fs" % (count, t))

Diff for: docs/source/examples/daVinci Word Count/wordfreq.py

@@ -19,7 +19,7 @@ def print_wordfreq(freqs, n=10):
     words, counts = freqs.keys(), freqs.values()
     items = zip(counts, words)
     items = sorted(items, reverse=True)
-    for (count, word) in items[:n]:
+    for count, word in items[:n]:
         print(word, count)
 
 

Diff for: docs/source/examples/dependencies.py

@@ -3,6 +3,7 @@
 
 client = ipp.Client()
 
+
 # this will only run on machines that can import numpy:
 @ipp.require('numpy')
 def norm(A):
@@ -32,6 +33,7 @@ def getpid():
 
 pid0 = client[0].apply_sync(getpid)
 
+
 # this will depend on the pid being that of target 0:
 @ipp.depend(checkpid, pid0)
 def getpid2():

Diff for: docs/source/examples/fetchparse.py

@@ -37,7 +37,6 @@ def fetchAndParse(url, data=None):
 
 
 class DistributedSpider:
-
     # Time to wait between polling for task results.
     pollingDelay = 0.5
 

Diff for: docs/source/examples/interengine/bintree.py

@@ -112,7 +112,6 @@ def disambiguate_dns_url(url, location):
 
 
 class BinaryTreeCommunicator:
-
     id = None
     pub = None
     sub = None

Diff for: docs/source/examples/interengine/bintree_script.py

@@ -49,6 +49,7 @@
 peers = ar.get_dict()
 # this is a dict, keyed by engine ID, of the connection info for the EngineCommunicators
 
+
 # connect the engines to each other:
 def connect(com, peers, tree, pub_url, root_id):
     """this function will be called on the engines"""
@@ -57,6 +58,7 @@ def connect(com, peers, tree, pub_url, root_id):
 
 view.apply_sync(connect, ipp.Reference('com'), peers, btree, pub_url, root_id)
 
+
 # functions that can be used for reductions
 # max and min builtins can be used as well
 def add(a, b):

Diff for: docs/source/examples/nwmerge.py

@@ -94,7 +94,6 @@ def remote_iterator(view, name):
 
 # Main, interactive testing
 if __name__ == '__main__':
-
     rc = ipp.Client()
     view = rc[:]
     print('Engine IDs:', rc.ids)

Diff for: docs/source/examples/wave2D/parallelwave-mpi.py

@@ -55,7 +55,6 @@ def wave_saver(u, x, y, t):
 
 # main program:
 if __name__ == '__main__':
-
     parser = argparse.ArgumentParser()
     paa = parser.add_argument
     paa(

Diff for: docs/source/examples/wave2D/parallelwave.py

@@ -60,7 +60,6 @@ def wave_saver(u, x, y, t):
 
 # main program:
 if __name__ == '__main__':
-
     parser = argparse.ArgumentParser()
     paa = parser.add_argument
     paa(

Diff for: docs/source/examples/wave2D/wavesolver.py

@@ -89,7 +89,6 @@ def __init__(
             'bc': 'vectorized',
         },
     ):
-
         nx = partitioner.global_num_cells[0]  # number of global cells in x dir
         ny = partitioner.global_num_cells[1]  # number of global cells in y dir
         dx = Lx / float(nx)

Diff for: ipyparallel/apps/iploggerapp.py

@@ -37,7 +37,6 @@
 
 
 class IPLoggerApp(BaseParallelApplication):
-
     name = 'iplogger'
     description = _description
     classes = [LogWatcher, ProfileDir]

Diff for: ipyparallel/client/client.py

@@ -402,7 +402,6 @@ def __init__(
         cluster=None,
         **extra_args,
     ):
-
         super_kwargs = {'debug': debug, 'cluster': cluster}
         if profile:
             super_kwargs['profile'] = profile
@@ -524,7 +523,6 @@ def __init__(
                 and not sshserver
                 and location != socket.gethostname()
             ):
-
                 # warn if no ssh specified, but SSH is probably needed
                 # This is only a warning, because the most likely cause
                 # is a local Controller on a laptop whose IP is dynamic

Diff for: ipyparallel/cluster/_winhpcjob.py

@@ -55,7 +55,6 @@ def find_username():
 
 
 class WinHPCJob(Configurable):
-
     job_id = Unicode('')
     job_name = Unicode('MyJob', config=True)
     min_cores = Integer(1, config=True)
@@ -149,7 +148,6 @@ def add_task(self, task):
 
 
 class WinHPCTask(Configurable):
-
     task_id = Unicode('')
     task_name = Unicode('')
     version = Unicode("2.000")
@@ -234,7 +232,6 @@ class IPEngineSetJob(WinHPCJob):
 
 
 class IPControllerTask(WinHPCTask):
-
     task_name = Unicode('IPController', config=True)
     controller_cmd = List(['ipcontroller.exe'], config=True)
     controller_args = List(['--log-level=40'], config=True)
@@ -262,7 +259,6 @@ def command_line(self):
 
 
 class IPEngineTask(WinHPCTask):
-
     task_name = Unicode('IPEngine', config=True)
     engine_cmd = List(['ipengine.exe'], config=True)
     engine_args = List(['--log-level=40'], config=True)

Diff for: ipyparallel/cluster/app.py

@@ -326,7 +326,6 @@ def start(self):
 
 
 class IPClusterEngines(BaseParallelApplication):
-
     name = 'ipcluster'
     description = engines_help
     examples = _engines_examples
@@ -545,7 +544,6 @@ def start(self):
 
 
 class IPClusterStart(IPClusterEngines):
-
     name = 'ipcluster'
     description = start_help
     examples = _start_examples

Diff for: ipyparallel/cluster/cluster.py

@@ -404,7 +404,6 @@ def __del__(self):
             self.stop_cluster_sync()
 
     def __repr__(self):
-
         fields = {
             "cluster_id": repr(self.cluster_id),
         }
@@ -1002,7 +1001,6 @@ def load_clusters(
             # TODO: only if it has any ipyparallel config files
             # *or* it's the default profile
             if init_default_clusters and not cluster_files:
-
                 cluster = Cluster(profile_dir=profile_dir, cluster_id="")
                 cluster_key = self._cluster_key(cluster)
                 if cluster_key not in self.clusters:

Diff for: ipyparallel/cluster/launcher.py

@@ -1395,7 +1395,6 @@ def remote_connection_files(self):
 
 
 class SSHControllerLauncher(SSHLauncher, ControllerLauncher):
-
     # alias back to *non-configurable* program[_args] for use in find_args()
     # this way all Controller/EngineSetLaunchers have the same form, rather
     # than *some* having `program_args` and others `controller_args`
@@ -1421,7 +1420,6 @@ def _to_fetch_default(self):
 
 
 class SSHEngineLauncher(SSHLauncher, EngineLauncher):
-
     # alias back to *non-configurable* program[_args] for use in find_args()
     # this way all Controller/EngineSetLaunchers have the same form, rather
     # than *some* having `program_args` and others `controller_args`
@@ -1579,7 +1577,6 @@ def start(self, n):
 
 
 class WindowsHPCLauncher(BaseLauncher):
-
     job_id_regexp = CRegExp(
         r'\d+',
         config=True,
@@ -1663,7 +1660,6 @@ def stop(self):
 
 
 class WindowsHPCControllerLauncher(WindowsHPCLauncher):
-
     job_file_name = Unicode(
         'ipcontroller_job.xml', config=True, help="WinHPC xml job file."
     )
@@ -1687,7 +1683,6 @@ def write_job_file(self, n):
 
 
 class WindowsHPCEngineSetLauncher(WindowsHPCLauncher):
-
     job_file_name = Unicode(
         'ipengineset_job.xml', config=True, help="jobfile for ipengines job"
     )

Diff for: ipyparallel/controller/app.py

@@ -166,7 +166,6 @@
 
 
 class IPController(BaseParallelApplication):
-
     name = 'ipcontroller'
     description = _description
     examples = _examples
@@ -996,7 +995,6 @@ def get_python_scheduler_args(
 
     def launch_broadcast_schedulers(self, monitor_url, children):
         def launch_in_thread_or_process(scheduler_args, depth, identity):
-
             if 'Process' in self.mq_class:
                 # run the Python scheduler in a Process
                 q = Process(
@@ -1012,7 +1010,6 @@ def launch_in_thread_or_process(scheduler_args, depth, identity):
                 launch_broadcast_scheduler(**scheduler_args)
 
         def recursively_start_schedulers(identity, depth):
-
             outgoing_id1 = identity + '0'
             outgoing_id2 = identity + '1'
             is_leaf = depth == self.broadcast_scheduler_depth

Diff for: ipyparallel/controller/scheduler.py

@@ -35,7 +35,6 @@ def logged(f, self, *args, **kwargs):
 
 
 class Scheduler(LoggingConfigurable):
-
     loop = Instance(ioloop.IOLoop)
 
     @default("loop")

Diff for: ipyparallel/engine/app.py

@@ -103,7 +103,6 @@
 
 
 class IPEngine(BaseParallelApplication):
-
     name = 'ipengine'
     description = _description
     examples = _examples

Diff for: ipyparallel/engine/datapub.py

@@ -10,7 +10,6 @@
 
 
 class ZMQDataPublisher(Configurable):
-
     topic = topic = CBytes(b'datapub')
     session = Instance(Session, allow_none=True)
     pub_socket = Any(allow_none=True)

Diff for: ipyparallel/error.py

@@ -170,7 +170,7 @@ def render_traceback(self, excid=None):
         """render one or all of my tracebacks to a list of lines"""
         lines = []
         if excid is None:
-            for (en, ev, etb, ei) in self.elist[: self.tb_limit]:
+            for en, ev, etb, ei in self.elist[: self.tb_limit]:
                 lines.append(self._get_engine_str(ei) + ":")
                 lines.extend((etb or 'No traceback available').splitlines())
                 lines.append('')

Diff for: ipyparallel/tests/__init__.py

@@ -49,7 +49,6 @@ def __str__(self):
 
 
 def setup():
-
     error.RemoteError = RemoteErrorWithTB
 
     cluster_dir = os.path.join(get_ipython_dir(), 'profile_iptest')

Diff for: ipyparallel/tests/test_apps.py

@@ -152,7 +152,6 @@ def ipcluster_list(*args):
 
 
 def test_ipcluster_list(Cluster):
-
     # no clusters
     out = ipcluster_list()
     assert len(out.splitlines()) == 1

Diff for: ipyparallel/tests/test_client.py

@@ -25,7 +25,6 @@
 
 @pytest.mark.usefixtures('ipython')
 class TestClient(ClusterTestCase):
-
     engine_count = 4
 
     def test_curve(self):
@@ -685,7 +684,6 @@ def test_wait_for_engines(self):
         sys.platform.startswith("win"), reason="Signal tests don't pass on Windows yet"
     )
     def test_signal_engines(self):
-
         view = self.client[:]
         if sys.platform.startswith("win"):
             signame = 'CTRL_C_EVENT'

Diff for: ipyparallel/tests/test_mpi.py

@@ -10,6 +10,7 @@
 
 # import tests that use engine_launcher_class fixture
 
+
 # override engine_launcher_class
 @pytest.fixture
 def engine_launcher_class():