Add missing type hints

Thanks, mypy/stubgen, for pointing out the Incomplete ones.

Author: ctrueden

src/appose/environment.py

@@ -42,8 +42,8 @@
 
 class Environment:
     def __init__(self, base: Path | str, use_system_path: bool = False):
-        self.base = Path(base).absolute()
-        self.use_system_path = use_system_path
+        self.base: Path = Path(base).absolute()
+        self.use_system_path: bool = use_system_path
 
     def python(self) -> Service:
         """

src/appose/python_worker.py

@@ -62,14 +62,14 @@ def __init__(
         inputs: Args | None = None,
     ) -> None:
         self._worker: Worker = worker or Worker()
-        self._uuid = uuid
-        self._script = script
-        self._inputs = inputs
+        self._uuid: str | None = uuid
+        self._script: str | None = script
+        self._inputs: Args | None = inputs
         self._finished = False
-        self._thread = None
+        self._thread: Thread | None = None
 
         # Public-facing fields for use within the task script.
-        self.outputs = {}
+        self.outputs: Args = {}
         self.cancel_requested = False
 
     def export(self, **kwargs):
@@ -80,7 +80,7 @@ def update(
         message: str | None = None,
         current: int | None = None,
         maximum: int | None = None,
-        info: dict[str, Any] | None = None,
+        info: Args | None = None,
     ) -> None:
         args = {}
         if message is not None:
@@ -195,9 +195,9 @@ def _respond(self, response_type: ResponseType, args: Args | None) -> None:
 
 class Worker:
     def __init__(self):
-        self.tasks = {}
+        self.tasks: dict[str, Task] = {}
         self.queue: list[Task] = []
-        self.exports = {}
+        self.exports[str, Any] = {}
 
         # Flag this process as a worker, not a service.
         _set_worker(True)

src/appose/service.py

@@ -52,13 +52,13 @@ class Service:
     service of updates via communication over pipes (stdin and stdout).
     """
 
-    _service_count = 0
+    _service_count: int = 0
 
     def __init__(self, cwd: str | Path, args: list[str]) -> None:
-        self._cwd = cwd
-        self._args = args[:]
+        self._cwd: str | Path = cwd
+        self._args: list[str] = args[:]
         self._tasks: dict[str, "Task"] = {}
-        self._service_id = Service._service_count
+        self._service_id: int = Service._service_count
         Service._service_count += 1
         self._process: subprocess.Popen | None = None
         self._stdout_thread: threading.Thread | None = None
@@ -283,14 +283,14 @@ def __init__(
         message: str | None = None,
         current: int | None = None,
         maximum: int | None = None,
-        info: dict[str, Any] | None = None,
+        info: Args | None = None,
     ) -> None:
         self.task: "Task" = task
         self.response_type: ResponseType = response_type
         self.message: str | None = message
         self.current: int | None = current
         self.maximum: int | None = maximum
-        self.info: dict[str, Any] | None = info
+        self.info: Args | None = info
 
     def __str__(self):
         return f"[{self.response_type}] {self.task}"
@@ -311,8 +311,8 @@ def __init__(
         queue: str | None = None,
     ) -> None:
         self.uuid: str = uuid4().hex
-        self.service = service
-        self.script = script
+        self.service: Service = service
+        self.script: str = script
         self.inputs: Args = {}
         self.queue: str | None = queue
         if inputs is not None:
@@ -324,7 +324,7 @@ def __init__(
         self.maximum: int = 1
         self.error: str | None = None
         self.listeners: list[Callable[["TaskEvent"], None]] = []
-        self.cv = threading.Condition()
+        self.cv: threading.Condition = threading.Condition()
         self.service._tasks[self.uuid] = self
 
     def start(self) -> "Task":

src/appose/types.py

@@ -68,8 +68,8 @@ def __init__(self, name: str = None, create: bool = False, rsize: int = 0):
             depending on the running platform.
         """
         super().__init__(name=name, create=create, size=rsize)
-        self.rsize = rsize
-        self._unlink_on_dispose = create
+        self.rsize: int = rsize
+        self._unlink_on_dispose: bool = create
         if _is_worker:
             # HACK: Remove this shared memory block from the resource_tracker,
             # which would otherwise want to clean up shared memory blocks
@@ -164,9 +164,9 @@ def __init__(self, dtype: str, shape: list[int], shm: SharedMemory = None):
                       with resolution 512x512 would have shape [7, 512, 512].
         :param shm: The SharedMemory containing the array data, or None to create it.
         """
-        self.dtype = dtype
-        self.shape = shape
-        self.shm = (
+        self.dtype: str = dtype
+        self.shape: list[int] = shape
+        self.shm: SharedMemory = (
             SharedMemory(
                 create=True, rsize=ceil(prod(shape) * _bytes_per_element(dtype))
             )