From 03ae87cb611046d25d01d8c42cf1ce82056ec4aa Mon Sep 17 00:00:00 2001 From: Willy Douhard Date: Thu, 7 Nov 2024 12:42:00 +0100 Subject: [PATCH] fix: tests --- literalai/event_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/literalai/event_processor.py b/literalai/event_processor.py index 8cf1fce..aae1f61 100644 --- a/literalai/event_processor.py +++ b/literalai/event_processor.py @@ -32,6 +32,7 @@ class EventProcessor: batch_timeout: float = 5.0 def __init__(self, api: "LiteralAPI", batch_size: int = 1, disabled: bool = False): + self.stop_event = threading.Event() self.batch_size = batch_size self.api = api self.event_queue = queue.Queue() @@ -44,7 +45,6 @@ def __init__(self, api: "LiteralAPI", batch_size: int = 1, disabled: bool = Fals ) if not self.disabled: self.processing_thread.start() - self.stop_event = threading.Event() def add_event(self, event: "StepDict"): with self.counter_lock: