diff --git a/labelbox/schema/project.py b/labelbox/schema/project.py
index bb2928412..84a141aeb 100644
--- a/labelbox/schema/project.py
+++ b/labelbox/schema/project.py
@@ -759,7 +759,7 @@ def create_batch(
             consensus_settings = ConsensusSettings(**consensus_settings).dict(
                 by_alias=True)
 
-        if len(dr_ids) >= 1_000:
+        if row_count >= 1_000:
             return self._create_batch_async(name, dr_ids, global_keys, priority,
                                             consensus_settings)
         else: