diff --git a/panoramisk/manager.py b/panoramisk/manager.py
index 881aebe..5dacb86 100644
--- a/panoramisk/manager.py
+++ b/panoramisk/manager.py
@@ -194,7 +194,7 @@ def connect(self, run_forever=False, on_startup=None, on_shutdown=None):
         """connect to the server"""
         if self.loop is None:  # pragma: no cover
             self.loop = asyncio.get_event_loop()
-        t = asyncio.create_task(
+        t = asyncio.ensure_future(
             self.loop.create_connection(
                 self.config['protocol_factory'],
                 self.config['host'], self.config['port'],