diff --git a/RFS/src/main/java/org/opensearch/migrations/bulkload/workcoordination/OpenSearchWorkCoordinator.java b/RFS/src/main/java/org/opensearch/migrations/bulkload/workcoordination/OpenSearchWorkCoordinator.java
index f1d9e801f..632161945 100644
--- a/RFS/src/main/java/org/opensearch/migrations/bulkload/workcoordination/OpenSearchWorkCoordinator.java
+++ b/RFS/src/main/java/org/opensearch/migrations/bulkload/workcoordination/OpenSearchWorkCoordinator.java
@@ -435,7 +435,7 @@ private int numWorkItemsArePending(
                         + " instead of 200"
                 );
             }
-            return resultHitsUpper.path("hits").size();
+            return resultHitsUpper.path("total").path("value").asInt();
         }
     }