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

pre-commit-ci[bot] · pre-commit-ci[bot] · commit 95dbcbb3301b · 2024-02-05T20:32:26.000Z
for more information, see https://pre-commit.ci
diff --git a/benchmarks/cluster_start.py b/benchmarks/cluster_start.py
@@ -19,12 +19,16 @@ def start_cluster(depth, number_of_engines, path='', log_output_to_file=False):
     ps = [
         Popen(
             ipcontroller_cmd.split(),
-            stdout=open('ipcontroller_output.log', 'a+')
-            if log_output_to_file
-            else sys.stdout,
-            stderr=open('ipcontroller_error_output.log', 'a+')
-            if log_output_to_file
-            else sys.stdout,
+            stdout=(
+                open('ipcontroller_output.log', 'a+')
+                if log_output_to_file
+                else sys.stdout
+            ),
+            stderr=(
+                open('ipcontroller_error_output.log', 'a+')
+                if log_output_to_file
+                else sys.stdout
+            ),
             stdin=sys.stdin,
         )
     ]
@@ -35,12 +39,16 @@ def start_cluster(depth, number_of_engines, path='', log_output_to_file=False):
         ps.append(
             Popen(
                 ipengine_cmd.split(),
-                stdout=open('ipengine_output.log', 'a+')
-                if log_output_to_file
-                else sys.stdout,
-                stderr=open('ipengine_error_output.log', 'a+')
-                if log_output_to_file
-                else sys.stdout,
+                stdout=(
+                    open('ipengine_output.log', 'a+')
+                    if log_output_to_file
+                    else sys.stdout
+                ),
+                stderr=(
+                    open('ipengine_error_output.log', 'a+')
+                    if log_output_to_file
+                    else sys.stdout
+                ),
                 stdin=sys.stdin,
             )
         )
diff --git a/benchmarks/gcloud_setup.py b/benchmarks/gcloud_setup.py
@@ -50,11 +50,15 @@ def delete_all_instances():
 def gcloud_run(*args, block=True):
     cmd = ["gcloud", "compute"] + list(args)
     print(f'$ {" ".join(cmd)}')
-    check_call(
-        cmd
-        # stdout=open(get_gcloud_log_file_name(instance_name) + ".log", "a+"),
-        # stderr=open(f"{get_gcloud_log_file_name(instance_name)}_error.out", "a+"),
-    ) if block else Popen(cmd)
+    (
+        check_call(
+            cmd
+            # stdout=open(get_gcloud_log_file_name(instance_name) + ".log", "a+"),
+            # stderr=open(f"{get_gcloud_log_file_name(instance_name)}_error.out", "a+"),
+        )
+        if block
+        else Popen(cmd)
+    )
 
 
 def copy_files_to_instance(instance_name, *file_names, directory="~"):
diff --git a/docs/source/examples/customresults.py b/docs/source/examples/customresults.py
@@ -9,6 +9,7 @@
 -------
 * MinRK
 """
+
 import random
 
 import ipyparallel as ipp
diff --git a/docs/source/examples/dagdeps.py b/docs/source/examples/dagdeps.py
@@ -6,6 +6,7 @@
 -------
 * MinRK
 """
+
 from random import randint
 
 import networkx as nx
diff --git a/docs/source/examples/fetchparse.py b/docs/source/examples/fetchparse.py
@@ -10,6 +10,7 @@
 
     ipcluster start -n 4
 """
+
 import sys
 import time
 
diff --git a/docs/source/examples/interengine/bintree.py b/docs/source/examples/interengine/bintree.py
@@ -6,6 +6,7 @@
 Provides parallel [all]reduce functionality
 
 """
+
 import re
 import socket
 from functools import reduce
diff --git a/docs/source/examples/iopubwatcher.py b/docs/source/examples/iopubwatcher.py
@@ -13,6 +13,7 @@
 -------
 * MinRK
 """
+
 import json
 import sys
 
diff --git a/docs/source/examples/itermapresult.py b/docs/source/examples/itermapresult.py
@@ -17,6 +17,7 @@
 -------
 * MinRK
 """
+
 import time
 
 import ipyparallel as ipp
diff --git a/docs/source/examples/nwmerge.py b/docs/source/examples/nwmerge.py
@@ -1,5 +1,6 @@
 """Example showing how to merge multiple remote data streams.
 """
+
 # Slightly modified version of:
 # https://aspn.activestate.com/ASPN/Cookbook/Python/Recipe/511509
 import heapq
diff --git a/docs/source/examples/phistogram.py b/docs/source/examples/phistogram.py
@@ -1,4 +1,5 @@
 """Parallel histogram function"""
+
 from ipyparallel import Reference
 
 
diff --git a/docs/source/examples/pi/parallelpi.py b/docs/source/examples/pi/parallelpi.py
@@ -15,6 +15,7 @@
 and the files used will be downloaded if they are not in the working directory
 of the IPython engines.
 """
+
 from timeit import default_timer as clock
 
 from matplotlib import pyplot as plt
diff --git a/docs/source/examples/pi/pidigits.py b/docs/source/examples/pi/pidigits.py
@@ -14,6 +14,7 @@
 If the digits of pi are truly random, these frequencies
 should be equal.
 """
+
 import os
 from urllib.request import urlretrieve
 
diff --git a/hatch_build.py b/hatch_build.py
@@ -1,4 +1,5 @@
 """Custom build script for hatch backend"""
+
 import glob
 import os
 import subprocess
diff --git a/ipyparallel/__init__.py b/ipyparallel/__init__.py
@@ -1,4 +1,5 @@
 """The IPython ZMQ-based parallel computing interface."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 # export return_when constants
diff --git a/ipyparallel/_async.py b/ipyparallel/_async.py
@@ -1,4 +1,5 @@
 """Async utilities"""
+
 import asyncio
 import concurrent.futures
 import inspect
diff --git a/ipyparallel/apps/baseapp.py b/ipyparallel/apps/baseapp.py
@@ -1,6 +1,7 @@
 """
 The Base Application class for ipyparallel apps
 """
+
 import logging
 import os
 import re
diff --git a/ipyparallel/apps/launcher.py b/ipyparallel/apps/launcher.py
@@ -1,4 +1,5 @@
 """Deprecated import for ipyparallel.cluster.launcher"""
+
 import warnings
 
 from ipyparallel.cluster.launcher import *  # noqa
diff --git a/ipyparallel/apps/logwatcher.py b/ipyparallel/apps/logwatcher.py
@@ -1,6 +1,7 @@
 """
 A logger object that consolidates messages incoming from ipcluster processes.
 """
+
 import logging
 
 import zmq
diff --git a/ipyparallel/client/_joblib.py b/ipyparallel/client/_joblib.py
@@ -1,4 +1,5 @@
 """joblib parallel backend for IPython Parallel"""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 from joblib.parallel import AutoBatchingMixin, ParallelBackendBase
diff --git a/ipyparallel/client/asyncresult.py b/ipyparallel/client/asyncresult.py
@@ -1,4 +1,5 @@
 """AsyncResult objects for the client"""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import concurrent.futures
diff --git a/ipyparallel/client/client.py b/ipyparallel/client/client.py
@@ -1,4 +1,5 @@
 """A semi-synchronous Client for IPython parallel"""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import asyncio
diff --git a/ipyparallel/client/futures.py b/ipyparallel/client/futures.py
@@ -1,4 +1,5 @@
 """Future-related utils"""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import sys
diff --git a/ipyparallel/client/magics.py b/ipyparallel/client/magics.py
@@ -25,6 +25,7 @@
 {CONFIG_DOC}
 
 """
+
 import time
 from contextlib import contextmanager
 
diff --git a/ipyparallel/client/map.py b/ipyparallel/client/map.py
@@ -3,6 +3,7 @@
 Scattering consists of partitioning a sequence and sending the various
 pieces to individual nodes in a cluster.
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import sys
diff --git a/ipyparallel/client/remotefunction.py b/ipyparallel/client/remotefunction.py
@@ -1,4 +1,5 @@
 """Remote Functions and decorators for Views."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import sys
diff --git a/ipyparallel/client/view.py b/ipyparallel/client/view.py
@@ -1,4 +1,5 @@
 """Views of remote engines."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import builtins
diff --git a/ipyparallel/cluster/_winhpcjob.py b/ipyparallel/cluster/_winhpcjob.py
@@ -2,6 +2,7 @@
 Job and task components for writing .xml files that the Windows HPC Server
 2008 can use to start jobs.
 """
+
 import os
 import re
 import uuid
diff --git a/ipyparallel/cluster/cluster.py b/ipyparallel/cluster/cluster.py
@@ -4,6 +4,7 @@
 
 starts/stops/polls controllers, engines, etc.
 """
+
 import asyncio
 import atexit
 import glob
diff --git a/ipyparallel/cluster/launcher.py b/ipyparallel/cluster/launcher.py
@@ -1,4 +1,5 @@
 """Facilities for launching IPython Parallel processes asynchronously."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import asyncio
diff --git a/ipyparallel/controller/app.py b/ipyparallel/controller/app.py
@@ -923,9 +923,9 @@ def init_hub(self):
             # save to new json config files
             base = {
                 'key': self.session.key.decode('ascii'),
-                'curve_serverkey': self.curve_publickey.decode("ascii")
-                if self.enable_curve
-                else None,
+                'curve_serverkey': (
+                    self.curve_publickey.decode("ascii") if self.enable_curve else None
+                ),
                 'location': self.location,
                 'pack': self.session.packer,
                 'unpack': self.session.unpacker,
@@ -982,9 +982,9 @@ def get_python_scheduler_args(
             'mon_addr': monitor_url,
             'not_addr': disambiguate_url(self.client_url('notification')),
             'reg_addr': disambiguate_url(self.client_url('registration')),
-            'identity': identity
-            if identity is not None
-            else bytes(scheduler_name, 'utf8'),
+            'identity': (
+                identity if identity is not None else bytes(scheduler_name, 'utf8')
+            ),
             'logname': logname,
             'loglevel': self.log_level,
             'log_url': self.log_url,
diff --git a/ipyparallel/controller/dependency.py b/ipyparallel/controller/dependency.py
@@ -1,5 +1,6 @@
 """Dependency utilities
 """
+
 from types import ModuleType
 
 from ipyparallel.client.asyncresult import AsyncResult
diff --git a/ipyparallel/controller/dictdb.py b/ipyparallel/controller/dictdb.py
@@ -32,6 +32,7 @@
 
     $lt,$gt,$lte,$gte,$ne,$in,$nin,$all,$mod,$exists
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import copy
diff --git a/ipyparallel/controller/hub.py b/ipyparallel/controller/hub.py
@@ -3,6 +3,7 @@
 This is the master object that handles connections from engines and clients,
 and monitors traffic through the various queues.
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import inspect
diff --git a/ipyparallel/controller/scheduler.py b/ipyparallel/controller/scheduler.py
@@ -4,6 +4,7 @@
 nor does it check msg_id DAG dependencies. For those, a slightly slower
 Python Scheduler exists.
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import logging
diff --git a/ipyparallel/controller/sqlitedb.py b/ipyparallel/controller/sqlitedb.py
@@ -1,4 +1,5 @@
 """A TaskRecord backend using sqlite3"""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import json
diff --git a/ipyparallel/engine/datapub.py b/ipyparallel/engine/datapub.py
@@ -1,4 +1,5 @@
 """Publishing native (typically pickled) objects."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 from ipykernel.jsonutil import json_clean
diff --git a/ipyparallel/engine/kernel.py b/ipyparallel/engine/kernel.py
@@ -1,4 +1,5 @@
 """IPython kernel for parallel computing"""
+
 import asyncio
 import inspect
 import sys
diff --git a/ipyparallel/engine/nanny.py b/ipyparallel/engine/nanny.py
@@ -13,6 +13,7 @@
   only engine *sets*
 - Cluster API can efficiently signal all engines via mpiexec
 """
+
 import asyncio
 import logging
 import os
diff --git a/ipyparallel/error.py b/ipyparallel/error.py
@@ -5,6 +5,7 @@
 .. inheritance-diagram:: ipyparallel.error
     :parts: 3
 """
+
 import builtins
 import sys
 import traceback
diff --git a/ipyparallel/joblib.py b/ipyparallel/joblib.py
@@ -16,6 +16,7 @@
 
 .. versionadded:: 5.1
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 from joblib.parallel import register_parallel_backend
diff --git a/ipyparallel/nbextension/__init__.py b/ipyparallel/nbextension/__init__.py
@@ -1,4 +1,5 @@
 """Jupyter server extension(s)"""
+
 import warnings
 
 
diff --git a/ipyparallel/nbextension/base.py b/ipyparallel/nbextension/base.py
@@ -1,4 +1,5 @@
 """Place to put the base Handler"""
+
 import warnings
 from functools import lru_cache
 
diff --git a/ipyparallel/nbextension/handlers.py b/ipyparallel/nbextension/handlers.py
@@ -1,4 +1,5 @@
 """Tornado handlers for IPython cluster web service."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import json
diff --git a/ipyparallel/nbextension/install.py b/ipyparallel/nbextension/install.py
@@ -2,6 +2,7 @@
 
 Only applicable for notebook < 7
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 from jupyter_core.paths import jupyter_config_dir
diff --git a/ipyparallel/serialize/canning.py b/ipyparallel/serialize/canning.py
@@ -1,4 +1,5 @@
 """Pickle-related utilities.."""
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import copy
diff --git a/ipyparallel/serialize/codeutil.py b/ipyparallel/serialize/codeutil.py
@@ -7,6 +7,7 @@
 
 Reference: A. Tremols, P Cogolo, "Python Cookbook," p 302-305
 """
+
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 import copyreg
diff --git a/ipyparallel/serialize/serialize.py b/ipyparallel/serialize/serialize.py
diff --git a/ipyparallel/tests/__init__.py b/ipyparallel/tests/__init__.py
diff --git a/ipyparallel/tests/clienttest.py b/ipyparallel/tests/clienttest.py
diff --git a/ipyparallel/tests/conftest.py b/ipyparallel/tests/conftest.py
diff --git a/ipyparallel/tests/test_apps.py b/ipyparallel/tests/test_apps.py
diff --git a/ipyparallel/tests/test_async.py b/ipyparallel/tests/test_async.py
diff --git a/ipyparallel/tests/test_asyncresult.py b/ipyparallel/tests/test_asyncresult.py
diff --git a/ipyparallel/tests/test_client.py b/ipyparallel/tests/test_client.py
diff --git a/ipyparallel/tests/test_db.py b/ipyparallel/tests/test_db.py
diff --git a/ipyparallel/tests/test_dependency.py b/ipyparallel/tests/test_dependency.py
diff --git a/ipyparallel/tests/test_executor.py b/ipyparallel/tests/test_executor.py
diff --git a/ipyparallel/tests/test_launcher.py b/ipyparallel/tests/test_launcher.py
diff --git a/ipyparallel/tests/test_lbview.py b/ipyparallel/tests/test_lbview.py
diff --git a/ipyparallel/tests/test_magics.py b/ipyparallel/tests/test_magics.py
diff --git a/ipyparallel/tests/test_mongodb.py b/ipyparallel/tests/test_mongodb.py
diff --git a/ipyparallel/tests/test_remotefunction.py b/ipyparallel/tests/test_remotefunction.py
diff --git a/ipyparallel/tests/test_serialize.py b/ipyparallel/tests/test_serialize.py
diff --git a/ipyparallel/tests/test_view.py b/ipyparallel/tests/test_view.py
diff --git a/ipyparallel/tests/test_view_broadcast.py b/ipyparallel/tests/test_view_broadcast.py
diff --git a/ipyparallel/traitlets.py b/ipyparallel/traitlets.py
diff --git a/ipyparallel/util.py b/ipyparallel/util.py
