remove typing

celery · Oct 21, 2024 · 13e673e · 13e673e
1 parent eb46270
commit 13e673e
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/celery/backends/asynchronous.py b/celery/backends/asynchronous.py
@@ -3,10 +3,8 @@
 import threading
 import time
 from collections import deque
-from collections.abc import Callable
 from queue import Empty
 from time import sleep
-from typing import Optional
 from weakref import WeakKeyDictionary
 
 from kombu.utils.compat import detect_environment
@@ -70,8 +68,8 @@ def wait_for(self, p, wait, timeout=None):
 
 
 class greenletDrainer(Drainer):
-    spawn: Callable[[Callable[[], None]], object]
-    _exc: Optional[Exception] = None
+    spawn = None
+    _exc = None
     _g = None
     _drain_complete_event = None    # event, sended (and recreated) after every drain_events iteration