diff --git a/src/modules/coral2_dws.py b/src/modules/coral2_dws.py
index 330aea8..2ae83f6 100755
--- a/src/modules/coral2_dws.py
+++ b/src/modules/coral2_dws.py
@@ -194,21 +194,21 @@ def get_datamovements(k8s_api, workflow_name, count):
     Return 'count' datamovements.
     """
     if LOGGER.isEnabledFor(logging.INFO):
-        limit = None
+        limit_arg = {}
     else:
         if count <= 0:
             return []
-        limit = count
+        limit_arg = {"limit": count}
     try:
         api_response = k8s_api.list_cluster_custom_object(
             group="nnf.cray.hpe.com",
             version="v1alpha2",
             plural="nnfdatamovements",
-            limit=limit,
             label_selector=(
                 f"dataworkflowservices.github.io/workflow.name={workflow_name},"
                 "dataworkflowservices.github.io/workflow.namespace=default"
             ),
+            **limit_arg,
         )
     except Exception as exc:
         LOGGER.warning(