diff --git a/rethinkdb/trio_net/net_trio.py b/rethinkdb/trio_net/net_trio.py
index 6ac42df2..bd0e5309 100644
--- a/rethinkdb/trio_net/net_trio.py
+++ b/rethinkdb/trio_net/net_trio.py
@@ -502,7 +502,7 @@ async def acquire(self):
                 # still connected.
                 conn = self._connections.popleft()
         except IndexError:
-            conn = await make_connection(*self._args, **self._kwargs)
+            conn = await make_connection(Connection, *self._args, **self._kwargs)
 
         self._lent_out.add(conn)
         return conn