From af66829e26cb05f182bef36ac06d58c7baa0ec1e Mon Sep 17 00:00:00 2001
From: Max Nanis
Date: Thu, 26 Feb 2026 20:29:41 -0500
Subject: AMTManager moved to fixture, and dectorator with parameters on tasks
 and init / non-static class appraoch. More assertion checks and typing.
 TestMTurkClient seperated from TestAMTManger

---
 jb/flow/events.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'jb/flow/events.py')

diff --git a/jb/flow/events.py b/jb/flow/events.py
index 5252fd0..60076de 100644
--- a/jb/flow/events.py
+++ b/jb/flow/events.py
@@ -96,9 +96,9 @@ def process_mturk_events_chunk(executor: Executor) -> Optional[int]:
 
 
 def process_assignment_submitted_event(event: MTurkEvent, msg_id: str):
-    from jb.decorators import AM, HM, BM
+    from jb.decorators import AMTM, AM, HM, BM
 
-    process_assignment_submitted(am=AM, hm=HM, bm=BM, event=event)
+    process_assignment_submitted(amtm=AMTM, am=AM, hm=HM, bm=BM, event=event)
     REDIS.xackdel(JB_EVENTS_STREAM, CONSUMER_GROUP, msg_id)
 
 
-- 
cgit v1.2.3