async def connect(self):
self.pool = await aiopg.create_pool(<EOL>loop=self.loop,<EOL>timeout=self.timeout,<EOL>database=self.database,<EOL>**self.connect_params)<EOL>
Create connection pool asynchronously.