             with r_server.pipeline() as pipe:                         while True:                             try:                                 pipe.watch('SET_WORKER_STATUS')                                 worker_key = self._nkey('worker_status:%s' % 