code: def set_queue_system_lock(self, queue, timeout):
          
  
          key = self._key(LOCK_REDIS_KEY, queue)
          Semaphore.set_system_lock(self.connection, key, timeout)
docs: Set system lock on a queue.
  
          Max workers for this queue must be used for this to have any effect.
  
          This will keep workers from processing tasks for this queue until
          the timeout has expired. Active tasks will continue processing their
          current task.
  
          timeout is number of seconds to hold the lock