code: def notify(self, new_jobs_count):
          
  
          if not self.use_notify():
              return
  
          # Not really useful to send more than 100 notifs (to be configured)
          count = min(new_jobs_count, 100)
  
          notify_key = redis_key("notify", self)
  
          context.connections.redis.lpush(notify_key, *([1] * count))
          context.connections.redis.expire(notify_key, max(1, int(context.get_current_config()["max_latency"] * 2)))
docs: We just queued new_jobs_count jobs on this queue, wake up the workers if needed