kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-06 10:25:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix detection of task transitioning to running

Browse Source
This commit is contained in:
Michael Schurter
2018-09-06 17:46:32 -07:00
parent 2b5d840eaa
commit 6ba5c7c76a
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client/allocrunnerv2/taskrunner/task_runner.go
View File

@@ -486,6 +486,7 @@ func (tr *TaskRunner) Restore() error {
// SetState sets the task runners allocation state and triggers a server
// update.
func (tr *TaskRunner) SetState(state string, event *structs.TaskEvent) {
tr.logger.Debug("setting task state", "state", state, "event", event.Type)
// Update the local state
stateCopy := tr.setStateLocal(state, event)
@@ -505,6 +506,7 @@ func (tr *TaskRunner) setStateLocal(state string, event *structs.TaskEvent) *str
}
// Update the task state
oldState := tr.state.State
taskState := tr.state
taskState.State = state
@@ -515,7 +517,7 @@ func (tr *TaskRunner) setStateLocal(state string, event *structs.TaskEvent) *str
switch state {
case structs.TaskStateRunning:
// Capture the start time if it is just starting
if taskState.State != structs.TaskStateRunning {
if oldState != structs.TaskStateRunning {
taskState.StartedAt = time.Now().UTC()
if !tr.clientConfig.DisableTaggedMetrics {
metrics.IncrCounterWithLabels([]string{"client", "allocs", "running"}, 1, tr.baseLabels)