fix fatal error

Signed-off-by: liuxu <liuxu623@gmail.com>
This commit is contained in:
liuxu 2019-10-14 21:41:29 +08:00
parent 0076f23195
commit 79322f2df2

View File

@ -18,6 +18,7 @@ import (
"context"
"fmt"
"math"
"sync"
"time"
"errors"
@ -45,6 +46,8 @@ type Context struct {
cfgMgr comcfg.CfgManager
// job life cycle tracker
tracker job.Tracker
// job logger configs settings map lock
lock sync.Mutex
}
// NewContext ...
@ -123,6 +126,8 @@ func (c *Context) Build(tracker job.Tracker) (job.Context, error) {
}
// Set loggers for job
c.lock.Lock()
defer c.lock.Unlock()
lg, err := createLoggers(tracker.Job().Info.JobID)
if err != nil {
return nil, err