Implement Connection._execute in terms of Connection.__execute

Author: elprans

asyncpg/connection.py

@@ -1198,11 +1198,9 @@ def _drop_global_statement_cache(self):
             self._drop_local_statement_cache()
 
     async def _execute(self, query, args, limit, timeout, return_status=False):
-        executor = lambda stmt, timeout: self._protocol.bind_execute(
-            stmt, args, '', limit, return_status, timeout)
-        timeout = self._protocol._get_timeout(timeout)
         with self._stmt_exclusive_section:
-            return await self._do_execute(query, executor, timeout)
+            return await self.__execute(query, args, limit, timeout,
+                                        return_status=return_status)
 
     async def __execute(self, query, args, limit, timeout,
                         return_status=False):