azure/k8s-deploy
1
0
Fork 0
mirror of https://github.com/Azure/k8s-deploy.git synced 2026-06-26 06:39:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add support for ScaledJob (#436)

Browse Source 
* Added ScaledJob support

* Fixed getReplicaCount error

* Fixed file length error in fileUtils.test.ts

* Adjust scaledJob spec path

* Made updateImagesInK8sObj more concise
This commit is contained in:
benjamin
2025-07-17 13:21:46 -04:00
committed by GitHub
parent 7a954ab84c
commit 4755eabeba
8 changed files with 256 additions and 104 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/utilities/manifestSpecLabelUtils.ts
+40 -16
View File
@@ -30,30 +30,54 @@ export function updateSpecLabels(
}
function getSpecLabels(inputObject: any) {
if (!inputObject) return null
const kind = inputObject?.kind?.toLowerCase()
const spec = inputObject?.spec
if (inputObject.kind.toLowerCase() === KubernetesWorkload.POD.toLowerCase())
return inputObject.metadata.labels
if (!inputObject || !kind) return null
if (inputObject?.spec?.template?.metadata)
return inputObject.spec.template.metadata.labels
switch (kind) {
case KubernetesWorkload.POD.toLowerCase():
return inputObject.metadata.labels
return null
case KubernetesWorkload.CRON_JOB.toLowerCase():
return spec?.jobTemplate?.spec?.template?.metadata?.labels
case KubernetesWorkload.SCALED_JOB.toLowerCase():
return spec?.jobTargetRef?.template?.metadata?.labels
default:
return spec?.template?.metadata?.labels || null
}
}
function setSpecLabels(inputObject: any, newLabels: any) {
if (!inputObject || !newLabels) return null
const kind = inputObject?.kind?.toLowerCase()
const spec = inputObject?.spec
if (
inputObject.kind.toLowerCase() === KubernetesWorkload.POD.toLowerCase()
) {
inputObject.metadata.labels = newLabels
return
}
if (!inputObject || !newLabels || !kind) return null
if (inputObject?.spec?.template?.metatada) {
inputObject.spec.template.metatada.labels = newLabels
return
switch (kind) {
case KubernetesWorkload.POD.toLowerCase():
inputObject.metadata.labels = newLabels
break
case KubernetesWorkload.CRON_JOB.toLowerCase():
if (spec?.jobTemplate?.spec?.template?.metadata) {
spec.jobTemplate.spec.template.metadata.labels = newLabels
}
break
case KubernetesWorkload.SCALED_JOB.toLowerCase():
if (spec?.jobTargetRef?.template?.metadata) {
spec.jobTargetRef.template.metadata.labels = newLabels
}
break
default:
if (spec?.template?.metadata) {
spec.template.metadata.labels = newLabels
}
break
}
}