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)