Method run

test/asynchronous/helpers.py:157–161

(self)

            return not self.stopped

    async def run(self):
        try:
            await self.target(*self.args)
        finally:
            self.stopped = True


class ExceptionCatchingTask(ConcurrentRunner):