Add some jitter in the processor fetch sleep

processor.go

@@ -179,7 +179,10 @@ func (p *processor) exec() {
  // Sleep to avoid slamming redis and let scheduler move tasks into queues.
  // Note: We are not using blocking pop operation and polling queues instead.
  // This adds significant load to redis.
- time.Sleep(100 * time.Millisecond)
+ avgWaitTime := 100
+ jitter := 40
+ waitTime := avgWaitTime - (jitter / 2) + rand.Intn(jitter)
+ time.Sleep(time.Duration(waitTime) * time.Millisecond)
  <-p.sema // release token
  return
  case err != nil: