code: def register_death(self):
          
          self.log.info('Registering death')
          with self.connection.pipeline() as p:
              p.hset(self.scheduler_key, 'death', time.time())
              p.expire(self.scheduler_key, 60)
              p.execute()
docs: Registers its own death.