code: async def _wait_execute(self, address, command, args, kw):
          
          conn = await self.acquire(command, args)
          try:
              return (await conn.execute(command, *args, **kw))
          finally:
              self.release(conn)
docs: Acquire connection and execute command.