Bump reqs.put timeout

Author: tsmith023

weaviate/collections/batch/async_.py

@@ -229,10 +229,10 @@ async def __loop(self) -> None:
                                 "Batch stream was not re-established within 5 minutes. Terminating batch."
                             )
                     try:
-                        await asyncio.wait_for(self.__reqs.put(req), timeout=10)
+                        await asyncio.wait_for(self.__reqs.put(req), timeout=60)
                     except asyncio.TimeoutError as e:
                         logger.warning(
-                            "Batch queue is blocked for more than 10 seconds. Exiting the loop"
+                            "Batch queue is blocked for more than 60 seconds. Exiting the loop"
                         )
                         self.__bg_exception = e
                         return

weaviate/collections/batch/sync.py

@@ -192,10 +192,10 @@ def __loop(self) -> None:
                                 "Batch stream was not re-established within 5 minutes. Terminating batch."
                             )
                     try:
-                        self.__reqs.put(req, timeout=10)
+                        self.__reqs.put(req, timeout=60)
                     except Full as e:
                         logger.warning(
-                            "Batch queue is blocked for more than 10 seconds. Exiting the loop"
+                            "Batch queue is blocked for more than 60 seconds. Exiting the loop"
                         )
                         self.__bg_exception = e
                         return