code: def wait_for_job(self):
          
          blpop_result = self.connection.blpop(self.keys, self.timeout)
          if blpop_result is None:
              return None
          queue_redis_key, job_ident = blpop_result
          self.set_status('running')
          return self.get_queue(queue_redis_key), self.get_job(job_ident)
docs: Use a redis blocking list call to wait for a job, and return it.