fix: queue types

Author: mrkaye97

hatchet_sdk/worker/action_listener_process.py

@@ -52,8 +52,8 @@ class WorkerActionListenerProcess:
     actions: List[str]
     max_runs: int
     config: ClientConfig
-    action_queue: Queue[Action]
-    event_queue: Queue[ActionEvent | STOP_LOOP_TYPE]
+    action_queue: "Queue[Action]"
+    event_queue: "Queue[ActionEvent | STOP_LOOP_TYPE]"
     handle_kill: bool = True
     debug: bool = False
     labels: dict[str, str | int] = field(default_factory=dict)

hatchet_sdk/worker/runner/run_loop_manager.py

@@ -27,8 +27,8 @@ class WorkerActionRunLoopManager:
     validator_registry: dict[str, WorkflowValidator]
     max_runs: int | None
     config: ClientConfig
-    action_queue: Queue[Action | STOP_LOOP_TYPE]
-    event_queue: Queue[ActionEvent]
+    action_queue: "Queue[Action | STOP_LOOP_TYPE]"
+    event_queue: "Queue[ActionEvent]"
     loop: asyncio.AbstractEventLoop
     handle_kill: bool = True
     debug: bool = False