async def stop(self):
    '\n        Cleanly shut down the watch task.\n        '
    self._stopping = True
    if (self.watch_task and (not self.watch_task.done())):
        self.watch_task.cancel()
        try:
            timeout = 5
            (await asyncio.wait_for(self.watch_task, timeout))
        except asyncio.TimeoutError:
            self.log.warning(f'Watch task did not finish in {timeout}s and was cancelled')
    self.watch_task = None
Cleanly shut down the watch task.
async def stop(self):
    '\n        \n        '
    self._stopping = True
    if (self.watch_task and (not self.watch_task.done())):
        self.watch_task.cancel()
        try:
            timeout = 5
            (await asyncio.wait_for(self.watch_task, timeout))
        except asyncio.TimeoutError:
            self.log.warning(f'Watch task did not finish in {timeout}s and was cancelled')
    self.watch_task = None