From 0bf32fadd85d5938ae29d489efdd82e2cd137300 Mon Sep 17 00:00:00 2001
From: Max Nanis
Date: Thu, 26 Feb 2026 15:51:49 -0500
Subject: Passing Managers into flow tasks for better pytest usage. Conftests
 broken out into seperate fixture files. Extensive type hinting.

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

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

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