Skip to content

Commit

Permalink
Filter Cronjob-created jobs from display
Browse files Browse the repository at this point in the history
  • Loading branch information
LeaveMyYard committed Apr 24, 2024
1 parent bf90978 commit 7cd0c59
Showing 1 changed file with 20 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,26 @@ async def list_workloads(self, namespaces: Union[list[str], Literal["*"]]) -> li
key = metric["namespace"], metric["owner_name"], metric["owner_kind"]
workloads[key].append(metric["pod"])

# NOTE: We do not show jobs that are a part of a cronjob, so we filter them out
job_workloads = [name for (_, name, kind) in workloads if kind == "Job"]
if job_workloads != []:
cronjobs = await self.connector.loader.query(
f"""
count by (namespace, job_name) (
kube_job_owner{{
{self.cluster_selector}
{namespace_selector},
owner_kind="CronJob"
}}
)
"""
)
for cronjob in cronjobs:
metric = cronjob["metric"]
key = (metric["namespace"], metric["job_name"], "Job")
if key in workloads:
del workloads[key]

workloads_containers = dict(
zip(
workloads.keys(),
Expand Down

0 comments on commit 7cd0c59

Please sign in to comment.