email integration

1 files changed, 1 insertions, 8 deletions

diff --git a/jb/flow/events.py b/jb/flow/events.py
index 04c4bb6..0eb91fd 100644
--- a/jb/flow/events.py
+++ b/jb/flow/events.py
@@ -2,7 +2,7 @@ import logging
 import time
 from concurrent import futures
 from concurrent.futures import Executor, ThreadPoolExecutor
-from typing import TypedDict, cast
+from typing import cast
 
 import redis
 
@@ -19,13 +19,6 @@ from jb.models.event import MTurkEvent
 StreamMessages = list[tuple[str, list[tuple[bytes, dict[bytes, bytes]]]]]
 
 
-class PendingEntry(TypedDict):
-    message_id: bytes
-    consumer: bytes
-    time_since_delivered: int
-    times_delivered: int
-
-
 def process_mturk_events_task():
     executor = ThreadPoolExecutor(max_workers=5)
     create_consumer_group()