kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-05 09:55:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2165 from hashicorp/b-driver-events

Browse Source 
Send Driver events to servers immediately
This commit is contained in:
Alex Dadgar
2017-01-09 11:23:38 -08:00
committed by GitHub
parent 4b72f11744 0641d8a3d1
commit c323bbde7d
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)