quick fix

aniketmaurya · Nov 30, 2023 · 7f7906c · 7f7906c
1 parent 762cb8c
commit 7f7906c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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):