From fcf7fe6aebdc325c189995d2c91e42d2308522bf Mon Sep 17 00:00:00 2001 From: Jason Parraga Date: Fri, 9 Aug 2024 06:43:14 -0700 Subject: [PATCH] fix: Fix armada executor job task interval variable (#3846) * Fix job task interval variable Signed-off-by: Jason Parraga * Address comment Signed-off-by: Jason Parraga --------- Signed-off-by: Jason Parraga Co-authored-by: Dejan Zele Pejchev Co-authored-by: Chris Martin --- config/executor/config.yaml | 2 +- internal/executor/application.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/config/executor/config.yaml b/config/executor/config.yaml index 8a5e3aacd83..b9974c37f9a 100644 --- a/config/executor/config.yaml +++ b/config/executor/config.yaml @@ -10,7 +10,7 @@ application: task: utilisationReportingInterval: 1s missingJobEventReconciliationInterval: 15s - jobLeaseRenewalInterval: 15s + jobLeaseRenewalInterval: 5s podIssueHandlingInterval: 10s podDeletionInterval: 5s resourceCleanupInterval: 15s diff --git a/internal/executor/application.go b/internal/executor/application.go index b1de6f094fc..b737eca2a71 100644 --- a/internal/executor/application.go +++ b/internal/executor/application.go @@ -250,7 +250,7 @@ func setupExecutorApiComponents( taskManager.Register(podIssueService.HandlePodIssues, config.Task.PodIssueHandlingInterval, "pod_issue_handling") taskManager.Register(preemptRunProcessor.Run, config.Task.StateProcessorInterval, "preempt_runs") taskManager.Register(removeRunProcessor.Run, config.Task.StateProcessorInterval, "remove_runs") - taskManager.Register(jobRequester.RequestJobsRuns, config.Task.AllocateSpareClusterCapacityInterval, "request_runs") + taskManager.Register(jobRequester.RequestJobsRuns, config.Task.JobLeaseRenewalInterval, "request_runs") taskManager.Register(clusterAllocationService.AllocateSpareClusterCapacity, config.Task.AllocateSpareClusterCapacityInterval, "submit_runs") taskManager.Register(eventReporter.ReportMissingJobEvents, config.Task.MissingJobEventReconciliationInterval, "event_reconciliation") _, err = pod_metrics.ExposeClusterContextMetrics(clusterContext, clusterUtilisationService, podUtilisationService, nodeInfoService)