Skip to content

Commit

Permalink
type fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
amyreese committed Apr 23, 2024
1 parent bba6e65 commit 2fb18f3
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions aiomultiprocess/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,12 +80,12 @@ class Process:
def __init__(
self,
group: None = None,
target: Callable = None,
name: str = None,
args: Sequence[Any] = None,
kwargs: Dict[str, Any] = None,
target: Optional[Callable] = None,
name: Optional[str] = None,
args: Optional[Sequence[Any]] = None,
kwargs: Optional[Dict[str, Any]] = None,
*,
daemon: bool = None,
daemon: Optional[bool] = None,
initializer: Optional[Callable] = None,
initargs: Sequence[Any] = (),
loop_initializer: Optional[Callable] = None,
Expand Down Expand Up @@ -152,7 +152,7 @@ def start(self) -> None:
"""Start the child process."""
return self.aio_process.start()

async def join(self, timeout: int = None) -> None:
async def join(self, timeout: Optional[int] = None) -> None:
"""Wait for the process to finish execution without blocking the main thread."""
if not self.is_alive() and self.exitcode is None:
raise ValueError("must start process before joining it")
Expand Down Expand Up @@ -227,7 +227,7 @@ def run_async(unit: Unit) -> R:
unit.namespace.result = e
raise

async def join(self, timeout: int = None) -> Any:
async def join(self, timeout: Optional[int] = None) -> Any:
"""Wait for the worker to finish, and return the final result."""
await super().join(timeout)
return self.result
Expand Down

0 comments on commit 2fb18f3

Please sign in to comment.