Call shutdown_asyncgens before loop closing (aio-libs#2227)

* Call shutdown_asyncgens before loop closing * Check for shutdown_asyncgens existance * Add changes
k4nar · Aug 27, 2017 · d7658d4 · d7658d4
1 parent 796c9ea
commit d7658d4
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/aiohttp/web.py b/aiohttp/web.py
@@ -464,6 +464,8 @@ def run_app(app, *, host=None, port=None, path=None, sock=None,
     finally:
         loop.run_until_complete(app.cleanup())
     if not user_supplied_loop:
+        if hasattr(loop, 'shutdown_asyncgens'):
+            loop.run_until_complete(loop.shutdown_asyncgens())
         loop.close()
 
 

diff --git a/aiohttp/worker.py b/aiohttp/worker.py
@@ -48,6 +48,8 @@ def run(self):
         try:
             self.loop.run_until_complete(self._runner)
         finally:
+            if hasattr(self.loop, 'shutdown_asyncgens'):
+                self.loop.run_until_complete(self.loop.shutdown_asyncgens())
             self.loop.close()
 
         sys.exit(self.exit_code)

diff --git a/changes/2227.feature b/changes/2227.feature
@@ -0,0 +1 @@
+Call `shutdown_asyncgens` before event loop closing on Python 3.6.