Skip to content

Commit

Permalink
rename multiprocessing module to avoid clash with standard lib module…
Browse files Browse the repository at this point in the history
… which led to a crash in pylint
  • Loading branch information
daniel-wer committed Jul 24, 2023
1 parent f603aa4 commit de4abb2
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion cluster_tools/cluster_tools/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@

from cluster_tools._utils.warning import enrich_future_with_uncaught_warning
from cluster_tools.executors.debug_sequential import DebugSequentialExecutor
from cluster_tools.executors.multiprocessing import MultiprocessingExecutor
from cluster_tools.executors.multiprocessing_ import MultiprocessingExecutor
from cluster_tools.executors.pickle import PickleExecutor
from cluster_tools.executors.sequential import SequentialExecutor
from cluster_tools.schedulers.cluster_executor import (
Expand Down
6 changes: 3 additions & 3 deletions cluster_tools/cluster_tools/executors/debug_sequential.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
from concurrent.futures import Future
from multiprocessing.context import BaseContext
from typing import Any, Callable, Optional, Tuple, TypeVar, cast

from typing import Callable, TypeVar, cast

from typing_extensions import ParamSpec

from cluster_tools._utils.warning import enrich_future_with_uncaught_warning
from cluster_tools.executors.multiprocessing import CFutDict, MultiprocessingExecutor
from cluster_tools.executors.multiprocessing_ import CFutDict, MultiprocessingExecutor
from cluster_tools.executors.sequential import SequentialExecutor

_T = TypeVar("_T")
Expand Down
2 changes: 1 addition & 1 deletion cluster_tools/cluster_tools/executors/pickle.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
from typing import Any, Callable, TypeVar

from cluster_tools._utils import pickling
from cluster_tools.executors.multiprocessing import MultiprocessingExecutor
from cluster_tools.executors.multiprocessing_ import MultiprocessingExecutor

_T = TypeVar("_T")

Expand Down
2 changes: 1 addition & 1 deletion cluster_tools/cluster_tools/executors/sequential.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from multiprocessing.context import BaseContext
from typing import Any, Callable, Optional, Tuple

from cluster_tools.executors.multiprocessing import MultiprocessingExecutor
from cluster_tools.executors.multiprocessing_ import MultiprocessingExecutor


class SequentialExecutor(MultiprocessingExecutor):
Expand Down
2 changes: 1 addition & 1 deletion cluster_tools/cluster_tools/schedulers/cluster_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
from cluster_tools._utils.string import random_string, with_preliminary_postfix
from cluster_tools._utils.tailf import Tail
from cluster_tools._utils.warning import enrich_future_with_uncaught_warning
from cluster_tools.executors.multiprocessing import CFutDict
from cluster_tools.executors.multiprocessing_ import CFutDict

NOT_YET_SUBMITTED_STATE_TYPE = Literal["NOT_YET_SUBMITTED"]
NOT_YET_SUBMITTED_STATE: NOT_YET_SUBMITTED_STATE_TYPE = "NOT_YET_SUBMITTED"
Expand Down

0 comments on commit de4abb2

Please sign in to comment.