def run()

in rlmeta/core/loop.py [0:0]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    def run(self) -> NoReturn:
        self._loop = asyncio.get_event_loop()
        self._tasks.append(
            asycio_utils.create_task(self._loop, self._check_phase()))
        for i, (env, agent) in enumerate(zip(self._envs, self._agents)):
            task = asycio_utils.create_task(
                self._loop, self._run_loop(env, agent, self.index_offset + i))
            self._tasks.append(task)
        try:
            self._loop.run_forever()
        except Exception as e:
            logging.error(e)
            raise e
        finally:
            for task in self._tasks:
                task.cancel()
            self._loop.stop()