code: async def disconnect(self):
          
          if self._connection:
              log.debug('Closing model connection')
              await self._connection.close()
              self._connection = None
docs: Shut down the watcher task and close websockets.