Skip to content

Commit

Permalink
fix: Fix armada executor job task interval variable (#3846)
Browse files Browse the repository at this point in the history
* Fix job task interval variable

Signed-off-by: Jason Parraga <[email protected]>

* Address comment

Signed-off-by: Jason Parraga <[email protected]>

---------

Signed-off-by: Jason Parraga <[email protected]>
Co-authored-by: Dejan Zele Pejchev <[email protected]>
Co-authored-by: Chris Martin <[email protected]>
  • Loading branch information
3 people authored Aug 9, 2024
1 parent c94dda7 commit fcf7fe6
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion config/executor/config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ application:
task:
utilisationReportingInterval: 1s
missingJobEventReconciliationInterval: 15s
jobLeaseRenewalInterval: 15s
jobLeaseRenewalInterval: 5s
podIssueHandlingInterval: 10s
podDeletionInterval: 5s
resourceCleanupInterval: 15s
Expand Down
2 changes: 1 addition & 1 deletion internal/executor/application.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit fcf7fe6

Please sign in to comment.