[Data] - Fix mongo datasource collStats invocation

goutamvenkat-anyscale · goutamvenkat-anyscale · commit b017c045afd1 · 2025-09-29T19:18:38.000-07:00
Signed-off-by: Goutam V. &lt;goutam@anyscale.com&gt;
diff --git a/python/ray/data/_internal/datasource/mongo_datasource.py b/python/ray/data/_internal/datasource/mongo_datasource.py
@@ -52,7 +52,7 @@ def _get_or_create_client(self):
                 self._client, self._database, self._collection
             )
             self._avg_obj_size = self._client[self._database].command(
-                "collstats", self._collection
+                "collStats", self._collection
             )["avgObjSize"]
 
     def get_read_tasks(

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ def _get_or_create_client(self):`
`52`	`52`	`self._client, self._database, self._collection`
`53`	`53`	`)`
`54`	`54`	`self._avg_obj_size = self._client[self._database].command(`
`55`		`- "collstats", self._collection`
	`55`	`+ "collStats", self._collection`
`56`	`56`	`)["avgObjSize"]`
`57`	`57`
`58`	`58`	`def get_read_tasks(`