async def METHOD_NAME(self, sql: sa.sql.base.Executable,
                 params: Union[Mapping[str, Any], None] = None
                ) -> Any:
    """ Execute a 'scalar()' query on the connection.
    """
    log().sql(self.connection, sql, params)
    return await asyncio.wait_for(self.connection.METHOD_NAME(sql, params), self.query_timeout)