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

Send Driver events to servers immediately

Browse Source 
This PR causes driver events to be sent to the server immediately rather
than waiting for Prestart() to finish.
This commit is contained in:
Alex Dadgar
2017-01-07 17:46:29 -08:00
parent 8214cf08c9
commit 0641d8a3d1
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client/task_runner.go
View File

@@ -361,7 +361,7 @@ func (r *TaskRunner) createDriver() (driver.Driver, error) {
eventEmitter := func(m string, args ...interface{}) {
msg := fmt.Sprintf(m, args...)
r.logger.Printf("[DEBUG] client: driver event for alloc %q: %s", r.alloc.ID, msg)
r.setState("", structs.NewTaskEvent(structs.TaskDriverMessage).SetDriverMessage(msg))
r.setState(structs.TaskStatePending, structs.NewTaskEvent(structs.TaskDriverMessage).SetDriverMessage(msg))
}
driverCtx := driver.NewDriverContext(r.task.Name, r.config, r.config.Node, r.logger, env, eventEmitter)