Vasanko/sanic
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix RuntimeError: this event loop is already running

Browse Source
This commit is contained in:
messense 2017-03-12 23:06:44 +08:00
parent 2b296435b3
commit f35442ad1b
No known key found for this signature in database
GPG Key ID: BB41A8A2C716CCA9
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sanic/worker.py
View File

@ -36,10 +36,12 @@ class GunicornWorker(base.Worker):
super().init_process() super().init_process()
def run(self): def run(self):
self._runner = asyncio.async(self._run(), loop=self.loop) self._runner = asyncio.ensure_future(self._run(), loop=self.loop)
try: try:
self.loop.run_until_complete(self._runner) self.loop.run_until_complete(self._runner)
trigger_events(self._server_settings.get('after_start', []), self.loop)
self.loop.run_until_complete(self._check_alive())
finally: finally:
trigger_events(self._server_settings.get('before_stop', []), self.loop) trigger_events(self._server_settings.get('before_stop', []), self.loop)
self.loop.close() self.loop.close()
@ -83,7 +85,7 @@ class GunicornWorker(base.Worker):
**self._server_settings **self._server_settings
)) ))
trigger_events(self._server_settings.get('after_start', []), self.loop) async def _check_alive(self):
# If our parent changed then we shut down. # If our parent changed then we shut down.
pid = os.getpid() pid = os.getpid()
try: try: