Skip to content
This repository was archived by the owner on Aug 5, 2025. It is now read-only.

Commit 03ae87c

Browse files
committed
fix: tests
1 parent 8c0c4c6 commit 03ae87c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

literalai/event_processor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ class EventProcessor:
3232
batch_timeout: float = 5.0
3333

3434
def __init__(self, api: "LiteralAPI", batch_size: int = 1, disabled: bool = False):
35+
self.stop_event = threading.Event()
3536
self.batch_size = batch_size
3637
self.api = api
3738
self.event_queue = queue.Queue()
@@ -44,7 +45,6 @@ def __init__(self, api: "LiteralAPI", batch_size: int = 1, disabled: bool = Fals
4445
)
4546
if not self.disabled:
4647
self.processing_thread.start()
47-
self.stop_event = threading.Event()
4848

4949
def add_event(self, event: "StepDict"):
5050
with self.counter_lock:

0 commit comments

Comments
 (0)