From 29491ad47a87e2459c50751ecdb16ebeb376be6f Mon Sep 17 00:00:00 2001 From: Diptanu Choudhury Date: Sun, 22 Nov 2015 23:47:15 -0800 Subject: [PATCH] Not restarting if a task exited properly --- client/task_runner.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/client/task_runner.go b/client/task_runner.go index c9720d10a..61223c45e 100644 --- a/client/task_runner.go +++ b/client/task_runner.go @@ -276,15 +276,17 @@ func (r *TaskRunner) run() { return } + waitEvent := r.waitErrorToEvent(waitRes) // Log whether the task was successful or not. if !waitRes.Successful() { r.logger.Printf("[ERR] client: failed to complete task '%s' for alloc '%s': %v", r.task.Name, r.allocID, waitRes) } else { r.logger.Printf("[INFO] client: completed task '%s' for alloc '%s'", r.task.Name, r.allocID) + r.setState(structs.TaskStateDead, waitEvent) + return } // Check if we should restart. If not mark task as dead and exit. - waitEvent := r.waitErrorToEvent(waitRes) shouldRestart, when := r.restartTracker.nextRestart() if !shouldRestart { r.logger.Printf("[INFO] client: Not restarting task: %v for alloc: %v ", r.task.Name, r.allocID)