# start fun _start(): await self.master.run() await self.master.running() self._task = self._loop.create_task(self._start()) self._loop.run_until_complete(self._task) # stop self.master.shutdown() self._task.done()