Fix.

Author: tobiasraabe

pyproject.toml

@@ -121,7 +121,6 @@ select = ["ALL"]
 "tests/*" = ["D", "ANN", "PLR2004", "S101"]
 "docs/source/conf.py" = ["INP001"]
 "docs_src/*" = ["ARG001", "D", "INP001", "S301"]
-"src/pytask_parallel/*.py" = ["PLC0415"]
 
 [tool.ruff.lint.isort]
 force-single-line = true

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

src/pytask_parallel/execute.py

@@ -195,7 +195,7 @@ 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 rewrap_task_with_coiled_function  # noqa: PLC0415
 
         wrapper_func = rewrap_task_with_coiled_function(task)
 
@@ -219,7 +219,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 +242,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

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(

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