code: async def restart_walk(self):
          
          if not self._restartwalk:
              self._restartwalk = True
              await self.wait_for_send(FlowUpdaterNotification(self, FlowUpdaterNotification.STARTWALK))
docs: Force a re-walk