diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 9bc6dcb..d50a1ca 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -22,17 +22,13 @@ repos: - id: python-no-log-warn - id: python-use-type-annotations - id: text-unicode-replacement-char -- repo: https://github.com/aio-libs/sort-all - rev: v1.3.0 - hooks: - - id: sort-all - repo: https://github.com/astral-sh/ruff-pre-commit - rev: v0.11.6 + rev: v0.12.4 hooks: - id: ruff - id: ruff-format - repo: https://github.com/dosisod/refurb - rev: v2.0.0 + rev: v2.1.0 hooks: - id: refurb - repo: https://github.com/kynan/nbstripout diff --git a/pyproject.toml b/pyproject.toml index a067839..6f548f5 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -111,8 +111,6 @@ unsafe-fixes = true [tool.ruff.lint] extend-ignore = [ - "ANN101", # type annotating self - "ANN102", # type annotating cls "ANN401", # flake8-annotate typing.Any "COM812", # Comply with ruff-format. "ISC001", # Comply with ruff-format. diff --git a/src/pytask_parallel/backends.py b/src/pytask_parallel/backends.py index a0e0b12..b889118 100644 --- a/src/pytask_parallel/backends.py +++ b/src/pytask_parallel/backends.py @@ -47,7 +47,7 @@ def submit( def _get_dask_executor(n_workers: int) -> Executor: """Get an executor from a dask client.""" _rich_traceback_guard = True - from pytask import import_optional_dependency + from pytask import import_optional_dependency # noqa: PLC0415 distributed = import_optional_dependency("distributed") assert distributed # noqa: S101 diff --git a/src/pytask_parallel/execute.py b/src/pytask_parallel/execute.py index d2e9cd3..84e1858 100644 --- a/src/pytask_parallel/execute.py +++ b/src/pytask_parallel/execute.py @@ -195,7 +195,9 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]: if is_coiled_function(task): # Prevent circular import for coiled backend. - from pytask_parallel.wrappers import rewrap_task_with_coiled_function + from pytask_parallel.wrappers import ( # noqa: PLC0415 + rewrap_task_with_coiled_function, + ) wrapper_func = rewrap_task_with_coiled_function(task) @@ -219,7 +221,7 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]: if worker_type == WorkerType.PROCESSES: # Prevent circular import for loky backend. - from pytask_parallel.wrappers import wrap_task_in_process + from pytask_parallel.wrappers import wrap_task_in_process # noqa: PLC0415 # Task modules are dynamically loaded and added to `sys.modules`. Thus, # cloudpickle believes the module of the task function is also importable in the @@ -242,7 +244,7 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]: if worker_type == WorkerType.THREADS: # Prevent circular import for loky backend. - from pytask_parallel.wrappers import wrap_task_in_thread + from pytask_parallel.wrappers import wrap_task_in_thread # noqa: PLC0415 return session.config["_parallel_executor"].submit( wrap_task_in_thread, task=task, remote=False, **kwargs diff --git a/src/pytask_parallel/utils.py b/src/pytask_parallel/utils.py index 2ab50f5..1db9ab2 100644 --- a/src/pytask_parallel/utils.py +++ b/src/pytask_parallel/utils.py @@ -50,7 +50,7 @@ def parse_future_result( future_exception = future.exception() if future_exception is not None: # Prevent circular import for loky backend. - from pytask_parallel.wrappers import WrapperResult + from pytask_parallel.wrappers import WrapperResult # noqa: PLC0415 exc_info = _parse_future_exception(future_exception) return WrapperResult( diff --git a/src/pytask_parallel/wrappers.py b/src/pytask_parallel/wrappers.py index a7b7d8c..acf6434 100644 --- a/src/pytask_parallel/wrappers.py +++ b/src/pytask_parallel/wrappers.py @@ -189,8 +189,8 @@ def _patch_set_trace_and_breakpoint() -> None: a subprocess and print a better exception message. """ - import pdb # noqa: T100 - import sys + import pdb # noqa: PLC0415, T100 + import sys # noqa: PLC0415 pdb.set_trace = _raise_exception_on_breakpoint sys.breakpointhook = _raise_exception_on_breakpoint