diff --git a/src/resin_cli/cli.py b/src/resin_cli/cli.py
index 81212e84..b34b71ed 100644
--- a/src/resin_cli/cli.py
+++ b/src/resin_cli/cli.py
@@ -281,7 +281,7 @@ def upsert(index_name: str,
     for i in range(0, len(data), batch_size):
         batch = data[i:i + batch_size]
         try:
-            kb.upsert(data)
+            kb.upsert(batch)
         except Exception as e:
             if allow_failures and len(failed_docs) < len(data) // 10:
                 failed_docs.extend([_.id for _ in batch])