@@ -672,17 +672,17 @@ async def _list_all_groupedjobs(self) -> list[K8sObjectData]:
672672 raise e
673673
674674 result = []
675- for group_name , lightweight_jobs in grouped_jobs .items ():
675+ for group_name , jobs in grouped_jobs .items ():
676676 # Get the one template job for this group
677677 template_job = grouped_jobs_template [group_name ]
678678
679679 # Group lightweight jobs by namespace
680680 jobs_by_namespace = defaultdict (list )
681- for lightweight_job in lightweight_jobs :
682- jobs_by_namespace [lightweight_job .namespace ].append (lightweight_job )
681+ for job in jobs :
682+ jobs_by_namespace [job .namespace ].append (job )
683683
684684 for namespace , namespace_jobs in jobs_by_namespace .items ():
685- limited_lightweight_jobs = namespace_jobs [:settings .job_grouping_limit ]
685+ limited_jobs = namespace_jobs [:settings .job_grouping_limit ]
686686
687687 container_names = set ()
688688 for container in template_job .spec .template .spec .containers :
@@ -705,7 +705,7 @@ async def _list_all_groupedjobs(self) -> list[K8sObjectData]:
705705 grouped_job .name = group_name
706706 grouped_job .namespace = namespace
707707 # Store only lightweight job info
708- grouped_job ._api_resource ._grouped_jobs = limited_lightweight_jobs
708+ grouped_job ._api_resource ._grouped_jobs = limited_jobs
709709 grouped_job ._api_resource ._label_filter = group_name
710710
711711 result .append (grouped_job )
0 commit comments