Allow fractional max retries

Author: tsmith023

weaviate/collections/batch/base.py

@@ -55,7 +55,7 @@
 CONCURRENT_REQUESTS_DYNAMIC_VECTORIZER = 2
 BATCH_TIME_TARGET = 10
 VECTORIZER_BATCHING_STEP_SIZE = 48  # cohere max batch size is 96
-MAX_RETRIES = int(os.getenv("WEAVIATE_BATCH_MAX_RETRIES", "9"))
+MAX_RETRIES = float(os.getenv("WEAVIATE_BATCH_MAX_RETRIES", "9"))
 
 
 class BatchRequest(ABC, Generic[TBatchInput, TBatchReturn]):

weaviate/collections/batch/grpc_batch_objects.py

@@ -78,7 +78,7 @@ def __grpc_objects(self, objects: List[_BatchObject]) -> List[batch_pb2.BatchObj
         ]
 
     async def objects(
-        self, objects: List[_BatchObject], timeout: Union[int, float], max_retries: int
+        self, objects: List[_BatchObject], timeout: Union[int, float], max_retries: float
     ) -> BatchObjectReturn:
         """Insert multiple objects into Weaviate through the gRPC API.
 
@@ -133,7 +133,7 @@ async def objects(
         )
 
     async def __send_batch(
-        self, batch: List[batch_pb2.BatchObject], timeout: Union[int, float], max_retries: int
+        self, batch: List[batch_pb2.BatchObject], timeout: Union[int, float], max_retries: float
     ) -> Dict[int, str]:
         try:
             assert self._connection.grpc_stub is not None

weaviate/collections/grpc/retry.py

@@ -13,7 +13,7 @@
 
 
 class _Retry:
-    def __init__(self, n: int = 4) -> None:
+    def __init__(self, n: float = 4) -> None:
         self.n = n
 
     async def with_exponential_backoff(