diff --git a/weaviate/tools/batcher.py b/weaviate/tools/batcher.py index 1c8ca0490..d1e44f0b1 100644 --- a/weaviate/tools/batcher.py +++ b/weaviate/tools/batcher.py @@ -107,7 +107,7 @@ def _update_batches_force(self): self._print_errors(result) self._reference_batch = weaviate.batch.ReferenceBatchRequest() - if self._return_values_callback is not None: + if self._return_values_callback is not None and len(result_collection) > 0: self._return_values_callback(result_collection) self._last_update = time.time()