Typing fixes

Author: dandavison

temporalio/worker/_activity.py

@@ -679,7 +679,7 @@ def _raise_in_thread_if_pending_unlocked(self) -> None:
 
 
 class _ActivityInboundImpl(ActivityInboundInterceptor):
-    def __init__(
+    def __init__(  # type: ignore[reportMissingSuperCall]
         self, worker: _ActivityWorker, running_activity: _RunningActivity
     ) -> None:
         # We are intentionally not calling the base class's __init__ here
@@ -786,7 +786,7 @@ async def heartbeat_with_context(*details: Any) -> None:
 
 
 class _ActivityOutboundImpl(ActivityOutboundInterceptor):
-    def __init__(self, worker: _ActivityWorker, info: temporalio.activity.Info) -> None:
+    def __init__(self, worker: _ActivityWorker, info: temporalio.activity.Info) -> None:  # type: ignore[reportMissingSuperCall]
         # We are intentionally not calling the base class's __init__ here
         self._worker = worker
         self._info = info

temporalio/worker/_worker.py

@@ -577,12 +577,12 @@ def config(self) -> WorkerConfig:
     @property
     def task_queue(self) -> str:
         """Task queue this worker is on."""
-        return self._config["task_queue"]
+        return self._config["task_queue"]  # type: ignore[reportTypedDictNotRequiredAccess]
 
     @property
     def client(self) -> temporalio.client.Client:
         """Client currently set on the worker."""
-        return self._config["client"]
+        return self._config["client"]  # type: ignore[reportTypedDictNotRequiredAccess]
 
     @client.setter
     def client(self, value: temporalio.client.Client) -> None:
@@ -679,9 +679,9 @@ async def raise_on_shutdown():
             )
             if exception:
                 logger.error("Worker failed, shutting down", exc_info=exception)
-                if self._config["on_fatal_error"]:
+                if self._config["on_fatal_error"]:  # type: ignore[reportTypedDictNotRequiredAccess]
                     try:
-                        await self._config["on_fatal_error"](exception)
+                        await self._config["on_fatal_error"](exception)  # type: ignore[reportTypedDictNotRequiredAccess]
                     except:
                         logger.warning("Fatal error handler failed")
 
@@ -692,7 +692,7 @@ async def raise_on_shutdown():
 
         # Cancel the shutdown task (safe if already done)
         tasks[None].cancel()
-        graceful_timeout = self._config["graceful_shutdown_timeout"]
+        graceful_timeout = self._config["graceful_shutdown_timeout"]  # type: ignore[reportTypedDictNotRequiredAccess]
         logger.info(
             f"Beginning worker shutdown, will wait {graceful_timeout} before cancelling activities"
         )

tests/worker/test_activity.py

@@ -612,7 +612,7 @@ async def some_activity(param1: SomeClass2, param2: str) -> str:
         result.result
         == "param1: <class 'tests.worker.test_activity.SomeClass2'>, param2: <class 'str'>"
     )
-    assert activity_param1 == SomeClass2(foo="str1", bar=SomeClass1(foo=123))
+    assert activity_param1 == SomeClass2(foo="str1", bar=SomeClass1(foo=123))  # type: ignore[reportUnboundVariable] # noqa
 
 
 async def test_activity_heartbeat_details(