diff options
| author | Max Nanis | 2026-02-27 20:29:40 -0500 |
|---|---|---|
| committer | Max Nanis | 2026-02-27 20:29:40 -0500 |
| commit | a11d3e562482abe909478f3c8bc1e7225fb095f9 (patch) | |
| tree | 6a194ea3439569a8588cd4a732156b4a43510742 | |
| parent | 758d60f4b6e46b2b601518cebee9af3b777f3c50 (diff) | |
| download | amt-jb-a11d3e562482abe909478f3c8bc1e7225fb095f9.tar.gz amt-jb-a11d3e562482abe909478f3c8bc1e7225fb095f9.zip | |
Updating py-utils to v3.3.4
| -rw-r--r-- | jb/flow/events.py | 2 | ||||
| -rw-r--r-- | requirements.txt | 2 |
2 files changed, 3 insertions, 1 deletions
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 diff --git a/requirements.txt b/requirements.txt index 04e12ab..8976073 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,4 +1,4 @@ -git+ssh://code.g-r-l.com:6611/py-utils@v3.2.2 +git+ssh://code.g-r-l.com:6611/py-utils@v3.3.4 aiohappyeyeballs==2.6.1 aiohttp==3.13.0 aiosignal==1.4.0 |