(self)
| 21 | self.exit_code = 0 |
| 22 | |
| 23 | def init_process(self): |
| 24 | # create new event_loop after fork |
| 25 | asyncio.get_event_loop().close() |
| 26 | |
| 27 | self.loop = asyncio.new_event_loop() |
| 28 | asyncio.set_event_loop(self.loop) |
| 29 | |
| 30 | super().init_process() |
| 31 | |
| 32 | def run(self): |
| 33 | self._runner = ensure_future(self._run(), loop=self.loop) |