From 7f7906c876de69032afa366b2a5123567e57a270 Mon Sep 17 00:00:00 2001 From: Aniket Maurya Date: Thu, 30 Nov 2023 15:01:05 +0000 Subject: [PATCH] quick fix --- src/fastserve/batching.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/fastserve/batching.py b/src/fastserve/batching.py index 391edfc..a4e4284 100644 --- a/src/fastserve/batching.py +++ b/src/fastserve/batching.py @@ -139,8 +139,7 @@ def process(self, item: Any): def cancel(self): logger.info("Terminating Batch Processor...") self._cancel_signal.set() - self._thread.terminate() - # self._thread.join() + self._thread.join() logger.info("Batch Processor terminated!") def signal_handler(self, sig, frame):