diff --git a/weaviate/collections/batch/base.py b/weaviate/collections/batch/base.py index f9c5e491a..efc7dd163 100644 --- a/weaviate/collections/batch/base.py +++ b/weaviate/collections/batch/base.py @@ -934,7 +934,7 @@ def _shutdown(self) -> None: # self.__batch_stream will set the shutdown event when it receives # the stop message from the server while self.__any_threads_alive(): - time.sleep(1) + time.sleep(0.05) logger.warning("Send & receive threads finished.") # copy the results to the public results