From a11d3e562482abe909478f3c8bc1e7225fb095f9 Mon Sep 17 00:00:00 2001 From: Max Nanis Date: Fri, 27 Feb 2026 20:29:40 -0500 Subject: Updating py-utils to v3.3.4 --- jb/flow/events.py | 2 ++ 1 file changed, 2 insertions(+) (limited to 'jb/flow/events.py') diff --git a/jb/flow/events.py b/jb/flow/events.py index 60076de..c759377 100644 --- a/jb/flow/events.py +++ b/jb/flow/events.py @@ -103,6 +103,8 @@ def process_assignment_submitted_event(event: MTurkEvent, msg_id: str): def handle_pending_msgs(): + # TODO!: This doesn't run at all. + # Looks in the redis queue for msgs that # are pending (read by a consumer but not ACK). These prob failed. # Below is from chatgpt, idk if it works -- cgit v1.2.3