remove extra logging in executor
This commit is contained in:
@@ -291,7 +291,6 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup
|
||||
for {
|
||||
select {
|
||||
case id := <-in:
|
||||
e.logger.Info("limitModeRunner got job", id)
|
||||
select {
|
||||
case <-e.ctx.Done():
|
||||
e.logger.Debug("limitModeRunner shutting down", "name", name)
|
||||
@@ -303,11 +302,9 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup
|
||||
ctx, cancel := context.WithCancel(e.ctx)
|
||||
j := requestJobCtx(ctx, id, e.jobOutRequest)
|
||||
if j != nil {
|
||||
e.logger.Info("limitModeRunner running job", id)
|
||||
e.runJob(*j)
|
||||
}
|
||||
cancel()
|
||||
e.logger.Info("limitModeRunner finished job", id)
|
||||
|
||||
// remove the limiter block to allow another job to be scheduled
|
||||
if limitMode == LimitModeReschedule {
|
||||
@@ -316,7 +313,6 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup
|
||||
default:
|
||||
}
|
||||
}
|
||||
e.logger.Info("limitModeRunner job done", id)
|
||||
case <-e.ctx.Done():
|
||||
e.logger.Debug("limitModeRunner shutting down", "name", name)
|
||||
wg.Done()
|
||||
|
||||
Reference in New Issue
Block a user