chore: determine wait batch size on batch size

Author: shortcuts

templates/go/ingestion_helpers.mustache

@@ -16,6 +16,8 @@ func (c *APIClient) ChunkedPush(indexName string, objects []map[string]any, acti
 		batchSize:    1000,
 	}
 
+  waitBatchSize := conf.batchSize / 10
+
 	for _, opt := range opts {
 		opt.apply(&conf)
 	}
@@ -60,11 +62,11 @@ func (c *APIClient) ChunkedPush(indexName string, objects []map[string]any, acti
 		}
 
 
-	  if conf.waitForTasks && (len(responses) % 50 == 0 || i == len(objects)-1) { 
+	  if conf.waitForTasks && (len(responses) % waitBatchSize == 0 || i == len(objects)-1) { 
       var waitableResponses []WatchResponse
 
-      if len(responses) > 50 {
-        waitableResponses = responses[len(responses)-50:]
+      if len(responses) > waitBatchSize {
+        waitableResponses = responses[len(responses)-waitBatchSize:]
       } else {
         waitableResponses = responses
       }

templates/java/api_helpers.mustache

@@ -45,9 +45,10 @@ public <T> List<WatchResponse> chunkedPush(
   List<WatchResponse> responses = new ArrayList<>();
   List<T> records = new ArrayList<>();
   Int count = 0;
+  Int waitBatchSize = batchSize / 10;
 
   for (T item : objects) {
-    if (records.size() == batchSize || count == objects.length() - 1) {
+    if (records.size() == batchSize || count == objects.size() - 1) {
       count++;
 
       WatchResponse watch =
@@ -64,8 +65,8 @@ public <T> List<WatchResponse> chunkedPush(
 
     records.add(item);
 
-    if (waitForTasks && (responses.size() % 50 == 0 || count == objects.length() - 1)) {
-          responses.subList(Math.max(responses.size() - 50, 0), responses.size()).forEach(response -> {
+    if (waitForTasks && (responses.size() % waitBatchSize == 0 || count == objects.size() - 1)) {
+          responses.subList(Math.max(responses.size() - waitBatchSize, 0), responses.size()).forEach(response -> {
           TaskUtils.retryUntil(
             () -> {
               try {

templates/php/api.mustache

@@ -337,6 +337,7 @@ use Algolia\AlgoliaSearch\Exceptions\NotFoundException;
         $responses = [];
         $records = [];
         $count = 0;
+        $waitBatchSize = (int)($batchSize / 10);
 
         foreach ($objects as $object) {
             $records[] = $object;
@@ -349,10 +350,10 @@ use Algolia\AlgoliaSearch\Exceptions\NotFoundException;
 
             ++$count;
 
-            if ($waitForTasks && (0 === count($responses) % 50 || $count === sizeof($objects) - 1)) {
+            if ($waitForTasks && (0 === count($responses) % $waitBatchSize || $count === sizeof($objects) - 1)) {
                 $timeoutCalculation = 'Algolia\AlgoliaSearch\Support\Helpers::linearTimeout';
 
-                foreach ($responses as $response) {
+                foreach (array_slice($responses, -waitBatchSize) as $response) {
                     $retry = 0;
 
                     while ($retry < 50) {

templates/python/ingestion_helpers.mustache

@@ -13,6 +13,7 @@
         """
         records: List[PushTaskRecords] = []
         responses: List[WatchResponse] = []
+        wait_batch_size = batch_size // 10
         for i, obj in enumerate(objects):
             records.append(obj)  # pyright: ignore
             if len(records) == batch_size or i == len(objects) - 1:
@@ -28,8 +29,8 @@
                     )
                 )
                 records = []
-            if wait_for_tasks and (len(responses) % 50 == 0 or i == len(objects) - 1):
-                for response in responses:
+            if wait_for_tasks and (len(responses) % wait_batch_size == 0 or i == len(objects) - 1):
+                for response in responses[-wait_batch_size:]:
                     {{^isSyncClient}}async {{/isSyncClient}}def _func(_: Optional[Event]) -> Event:
                         if response.event_id is None:
                             raise ValueError(