def METHOD_NAME(self, exception, poller_id):
    # try to reconnect the pv
    self.pv.connect()
    poller = Poller.get_poller(poller_id)
    if poller is not None:
        try:
            poller.restart(1000)
        except Exception:
            pass