fix: 0

Author: mrkaye97

hatchet_sdk/clients/workflow_listener.py

@@ -119,7 +119,7 @@ async def _init_producer(self) -> None:
 
                                 t.cancel()
                                 if self.listener:
-                                    self.listener.cancel() # type: ignore[attr-defined]
+                                    self.listener.cancel()  # type: ignore[attr-defined]
                                 await asyncio.sleep(
                                     DEFAULT_WORKFLOW_LISTENER_RETRY_INTERVAL
                                 )

hatchet_sdk/worker/runner/utils/capture_logs.py

@@ -42,7 +42,7 @@ def filter(self, record: logging.LogRecord) -> bool:
         return True
 
 
-class CustomLogHandler(logging.StreamHandler):
+class CustomLogHandler(logging.StreamHandler[Any]):
     def __init__(self, event_client: EventClient, stream: StringIO | None = None):
         super().__init__(stream)
         self.logger_thread_pool = ThreadPoolExecutor(max_workers=1)