@@ -195,7 +195,9 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]:
195195
196196 if is_coiled_function (task ):
197197 # Prevent circular import for coiled backend.
198- from pytask_parallel .wrappers import rewrap_task_with_coiled_function
198+ from pytask_parallel .wrappers import ( # noqa: PLC0415
199+ rewrap_task_with_coiled_function ,
200+ )
199201
200202 wrapper_func = rewrap_task_with_coiled_function (task )
201203
@@ -219,7 +221,7 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]:
219221
220222 if worker_type == WorkerType .PROCESSES :
221223 # Prevent circular import for loky backend.
222- from pytask_parallel .wrappers import wrap_task_in_process
224+ from pytask_parallel .wrappers import wrap_task_in_process # noqa: PLC0415
223225
224226 # Task modules are dynamically loaded and added to `sys.modules`. Thus,
225227 # 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]:
242244
243245 if worker_type == WorkerType .THREADS :
244246 # Prevent circular import for loky backend.
245- from pytask_parallel .wrappers import wrap_task_in_thread
247+ from pytask_parallel .wrappers import wrap_task_in_thread # noqa: PLC0415
246248
247249 return session .config ["_parallel_executor" ].submit (
248250 wrap_task_in_thread , task = task , remote = False , ** kwargs
0 commit comments