From f3e37a1c73bd0d68966f24995011b5c93305273d Mon Sep 17 00:00:00 2001
From: stuppie
Date: Tue, 8 Sep 2026 16:02:08 -0600
Subject: email integration

---
 jb/flow/events.py | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

(limited to 'jb/flow')

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()
-- 
cgit v1.2.3