diff --git a/src/jobservice/job/impl/context.go b/src/jobservice/job/impl/context.go index 5dff0e74d..2928defab 100644 --- a/src/jobservice/job/impl/context.go +++ b/src/jobservice/job/impl/context.go @@ -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