changes improvements

Author: Avi-Robusta

robusta_krr/core/integrations/kubernetes/__init__.py

@@ -277,7 +277,7 @@ async def _list_namespaced_or_global_objects_batched(
         limit: Optional[int] = None,
         continue_ref: Optional[str] = None,
     ) -> tuple[list[Any], Optional[str]]:
-        logger.debug(f"Listing {kind}s in {self.cluster} with batching (limit={limit})")
+        logger.debug("Listing %s in %s with batching (limit=%d)", kind, self.cluster, limit)
         loop = asyncio.get_running_loop()
 
         try:

robusta_krr/main.py

@@ -232,6 +232,18 @@ def run_strategy(
                     help="Maximum number of jobs/pods to query per GroupedJob group (default: 500).",
                     rich_help_panel="Job Grouping Settings",
                 ),
+                discovery_job_batch_size: int = typer.Option(
+                    1000,
+                    "--discovery-job-batch-size",
+                    help="Batch size for Kubernetes job API calls (default: 1000).",
+                    rich_help_panel="Job Discovery Settings",
+                ),
+                discovery_job_max_batches: int = typer.Option(
+                    50,
+                    "--discovery-job-max-batches",
+                    help="Maximum number of job batches to process to prevent infinite loops (default: 50).",
+                    rich_help_panel="Job Discovery Settings",
+                ),
                 format: str = typer.Option(
                     "table",
                     "--formatter",
@@ -371,6 +383,8 @@ def run_strategy(
                         max_workers=max_workers,
                         job_grouping_labels=job_grouping_labels,
                         job_grouping_limit=job_grouping_limit,
+                        discovery_job_batch_size=discovery_job_batch_size,
+                        discovery_job_max_batches=discovery_job_max_batches,
                         format=format,
                         show_cluster_name=show_cluster_name,
                         verbose=verbose,