Merge pull request #864 from ipython/pre-commit-ci-update-config

[pre-commit.ci] pre-commit autoupdate

.pre-commit-config.yaml

@@ -15,7 +15,7 @@ repos:
       - id: isort
         exclude: setupbase.py
   - repo: https://github.com/psf/black
-    rev: 23.12.1
+    rev: 24.1.1
     hooks:
       - id: black
         exclude: setupbase.py
@@ -24,7 +24,7 @@ repos:
     hooks:
       - id: prettier
   - repo: https://github.com/PyCQA/flake8
-    rev: "6.1.0"
+    rev: "7.0.0"
     hooks:
       - id: flake8
   - repo: https://github.com/pre-commit/pre-commit-hooks
@@ -35,7 +35,7 @@ repos:
       - id: check-executables-have-shebangs
       - id: requirements-txt-fixer
   - repo: https://github.com/pre-commit/mirrors-eslint
-    rev: v9.0.0-alpha.0
+    rev: v9.0.0-alpha.2
     hooks:
       - id: eslint
         files: \.[jt]sx?$ # *.js, *.jsx, *.ts and *.tsx

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,
             )
         )

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="~"):

docs/source/examples/customresults.py

@@ -9,6 +9,7 @@
 -------
 * MinRK
 """
+
 import random
 
 import ipyparallel as ipp

docs/source/examples/dagdeps.py

@@ -6,6 +6,7 @@
 -------
 * MinRK
 """
+
 from random import randint
 
 import networkx as nx

docs/source/examples/fetchparse.py

@@ -10,6 +10,7 @@
 
     ipcluster start -n 4
 """
+
 import sys
 import time
 

docs/source/examples/interengine/bintree.py

@@ -6,6 +6,7 @@
 Provides parallel [all]reduce functionality
 
 """
+
 import re
 import socket
 from functools import reduce

docs/source/examples/iopubwatcher.py

@@ -13,6 +13,7 @@
 -------
 * MinRK
 """
+
 import json
 import sys
 

docs/source/examples/itermapresult.py

@@ -17,6 +17,7 @@
 -------
 * MinRK
 """
+
 import time
 
 import ipyparallel as ipp

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

docs/source/examples/phistogram.py

@@ -1,4 +1,5 @@
 """Parallel histogram function"""
+
 from ipyparallel import Reference
 
 

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

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
 

hatch_build.py

@@ -1,4 +1,5 @@
 """Custom build script for hatch backend"""
+
 import glob
 import os
 import subprocess

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

ipyparallel/_async.py

@@ -1,4 +1,5 @@
 """Async utilities"""
+
 import asyncio
 import concurrent.futures
 import inspect

ipyparallel/apps/baseapp.py

@@ -1,6 +1,7 @@
 """
 The Base Application class for ipyparallel apps
 """
+
 import logging
 import os
 import re

ipyparallel/apps/launcher.py

@@ -1,4 +1,5 @@
 """Deprecated import for ipyparallel.cluster.launcher"""
+
 import warnings
 
 from ipyparallel.cluster.launcher import *  # noqa

ipyparallel/apps/logwatcher.py

@@ -1,6 +1,7 @@
 """
 A logger object that consolidates messages incoming from ipcluster processes.
 """
+
 import logging
 
 import zmq

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

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

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

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

ipyparallel/client/magics.py

@@ -25,6 +25,7 @@
 {CONFIG_DOC}
 
 """
+
 import time
 from contextlib import contextmanager
 

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

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

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

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

ipyparallel/cluster/cluster.py

@@ -4,6 +4,7 @@
 
 starts/stops/polls controllers, engines, etc.
 """
+
 import asyncio
 import atexit
 import glob

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

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,

ipyparallel/controller/dependency.py

@@ -1,5 +1,6 @@
 """Dependency utilities
 """
+
 from types import ModuleType
 
 from ipyparallel.client.asyncresult import AsyncResult

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

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

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

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

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

ipyparallel/engine/kernel.py

@@ -1,4 +1,5 @@
 """IPython kernel for parallel computing"""
+
 import asyncio
 import inspect
 import sys

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

ipyparallel/error.py

@@ -5,6 +5,7 @@
 .. inheritance-diagram:: ipyparallel.error
     :parts: 3
 """
+
 import builtins
 import sys
 import traceback

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

ipyparallel/nbextension/__init__.py

@@ -1,4 +1,5 @@
 """Jupyter server extension(s)"""
+
 import warnings
 
 

ipyparallel/nbextension/base.py

@@ -1,4 +1,5 @@
 """Place to put the base Handler"""
+
 import warnings
 from functools import lru_cache