Использование декораторов

class OraclePool(object):
    """
    Класс максимально возможно реализующий асинхронный интерфейс для работы с cx_Oracle.
    Под асинхронным подразумевается asyncio-совместимый
    Единственный нюанс - пока неясно насколько быстро все это работает.
    """
 
    def __init__(self, pool: cx_Oracle.SessionPool, dbname: str = '',
                 connection: cx_Oracle.Connection = None, cursor: cx_Oracle.Cursor = None,
                 loop: asyncio.events.AbstractEventLoop = asyncio.get_event_loop(),
                 session: bool = False):
        """
        Конструктор. Ничего важного не делает.
        Проверяет, чтобы cursor и connection были None
        :param pool: пул соединений к бд
        :param dbname: наименование бд. Можно не указывать. Параметр чисто на всякий случай.
        Кандидат на удаление
        :param connection: Текущее соединение к бд. Создается автоматически при входе в блок with
        :param cursor: Текущий курсор базы данны. Создается автоматически при входе в блок with
        :param loop: Экземпляр asyncio.events.AbstractEventLoop или его наследник.\
         Нужен для определения в контексте какого loop мы выполняем код
        :param session: Выполнять ли запросы в рамках сессии. Нужно только для бд Hydra.
        """
        self.pool = pool
        self.dbname = dbname
        self.connection = connection
        self.cursor = cursor
        self.loop = loop
        self.session = session
 
        if cursor or connection:
            raise Exception('Параметры cursor и connection не должны указываться')
 
    async def execute_async(self, func, *args, **kwargs):
        """
        "Асинхронный запускатор и выполнятор" любой функции
        :param func: функция
        :param args: позиционные аргументы
        :param kwargs: именованные аргументы
        :return: результат асинхронно выполненой функции
        """
        function = partial(func, *args, **kwargs)
        f = self.loop.run_in_executor(None, function)
        data = await f
        return data
 
    async def call_proc(self, name: str, keywordparameters: dict):
        kwargs = {'name': name, 'keywordParameters': keywordparameters}
        await self.execute_async(self.cursor.callproc, **kwargs)
 
    async def __aenter__(self):
        """
        Реализация менеджера контекста, в котором осуществляется подключение к базе данных.
        Если параметр session равен True - осуществляется инициализация сессии к базе данных.
        :return:
        """
        self.connection = await self.execute_async(self.pool.acquire)
        assert isinstance(self.connection, cx_Oracle.Connection)
 
        self.cursor = await self.execute_async(self.connection.cursor)
        assert isinstance(self.cursor, cx_Oracle.Cursor)
 
        if self.session:
            await self.execute_async(self.cursor.callproc, **settings.INIT_SESSION)
            await self.execute_async(self.cursor.callproc, **settings.SET_ACTIVE_FIRM)
 
        return self
 
    async def __aexit__(self, exc_type, exc_val, exc_tb):
        """
        Реализация выхода из менеджера контекста, в котором осуществляется подключение к базе данных.
        Все возможные ошибки на текущий момент не обрабатываются.
        Для их игнорирования в функцию нужно добавить return True
        Если параметр session равен True - осуществляется закрытие сессии в базе данных.
        :param exc_type: тип исключения
        :param exc_val: экземпляр исключения
        :param exc_tb:  трейсбек исключения
        :return:
        """
        if self.session:
            await self.execute_async(self.cursor.callproc, **settings.CLOSE_SESSION)
        self.cursor.close()
        self.connection.close()
 
    @check_connection
    async def commit(self):
        """
        Функция-обертка делающая коммит в бд
        :return:
        """
        await self.execute_async(self.connection.commit)
 
    @check_connection
    async def test_query(self):
        sql = "SELECT * FROM si_v_subj_accounts WHERE VC_Account='3669143'"
        return await self.query_names(sql)
 
    @check_connection
    async def test_long_query(self):
        sql = """
        SELECT  si_ref_pkg_s.GET_NAME_BY_ID(
            SI_SUBJECTS_PKG_S.GET_SUBJ_TYPE_ID(
                SI_SUBJECTS_PKG_S.GET_BASE_SUBJECT_ID(
                    sub.N_SUBJECT_ID))) "Тип абонента",
            si_ref_pkg_s.GET_NAME_BY_ID(gv.N_REF_ID) "Тип услуги",
            sr_goods_pkg_s.GET_NAME_BY_ID(sub.N_SERVICE_ID) "Услуга",
            count(DISTINCT sub.N_DOC_ID) "Договора",count(DISTINCT sub.N_SUBSCRIPTION_ID) "Подписки"
        FROM  si_subscriptions sub
        INNER JOIN sr_good_values gv ON gv.N_GOOD_ID=sub.N_SERVICE_ID
            AND gv.N_GOOD_VALUE_TYPE_ID IN (2149605401, 2149632001, 2149755901, 2149757501)
            AND gv.C_ACTIVE='Y'
        WHERE sub.C_FL_CLOSED='N'AND (sub.D_END IS NULL OR sub.D_END>=sysdate) 
        AND sub.C_ACTIVE='Y' AND sub.D_BEGIN<=sysdate
        GROUP BY    sr_goods_pkg_s.GET_NAME_BY_ID(sub.N_SERVICE_ID), 
            si_ref_pkg_s.GET_NAME_BY_ID(gv.N_REF_ID),
            si_ref_pkg_s.GET_NAME_BY_ID(
                SI_SUBJECTS_PKG_S.GET_SUBJ_TYPE_ID(
                    SI_SUBJECTS_PKG_S.GET_BASE_SUBJECT_ID(sub.N_SUBJECT_ID)))
        ORDER BY sr_goods_pkg_s.GET_NAME_BY_ID(sub.N_SERVICE_ID), 
        si_ref_pkg_s.GET_NAME_BY_ID(
            SI_SUBJECTS_PKG_S.GET_SUBJ_TYPE_ID(
            SI_SUBJECTS_PKG_S.GET_BASE_SUBJECT_ID(sub.N_SUBJECT_ID))),
                si_ref_pkg_s.GET_NAME_BY_ID(gv.N_REF_ID)
                """
        return await self.query_names(sql)
 
    @check_connection
    async def query(self, sql: str, args=None, one: bool = False, update: bool = False):
        """
        Делаем произвольный запрос к бд. Возвращаем полученные данные
        :param sql: текст запроса
        :param args: параметры запроса
        :param one: True - выдавать одну запись. False (идет по умолчанию) -  все
        :param update: Нужно ли делать коммит после выполнения запроса. По умолчанию False
        :return: Полученные из бд данные
        """
        if args is None:
            await self.execute_async(self.cursor.execute, sql)
        else:
            await self.execute_async(self.cursor.execute, sql, args)
        if update:
            await self.commit()
            return self.cursor.rowcount
        if one:
            return await self.execute_async(self.cursor.fetchone)
        else:
            return await self.execute_async(self.cursor.fetchall)
 
    @check_connection
    async def query_names(self, sql: str, args=None, one: bool = False, update: bool = False):
        """
        Делаем произвольный запрос к бд. Возвращаем полученные данные.
        Данные возвращаются в виде списка словарей, ключ в которых - наименование колонки из
        sql запроса.
        :param sql: текст запроса
        :param args: параметры запроса
        :param one: True - выдавать одну запись. False (идет по умолчанию) -  все
        :param update: Нужно ли делать коммит после выполнения запроса. По умолчанию False
        :return: Полученные из бд данные
        """
        if args is None:
            await self.execute_async(self.cursor.execute, sql)
        else:
            await self.execute_async(self.cursor.execute, sql, args)
        if update:
            await self.commit()
            return self.cursor.rowcount
        if one:
            return [dict((self.cursor.description[idx][0], value)
                         for idx, value in enumerate(await self.execute_async(self.cursor.fetchone)))]
        else:
            return [dict((self.cursor.description[idx][0], value)
                         for idx, value in enumerate(row))
                    for row in await self.execute_async(self.cursor.fetchall)]

def my_dec(func):
    def wrapper(*arg, **kw):
        return func(*arg, **kw)
    return wrapper
 
 
@my_dec
def some_func(my_var):
    print(my_var)
 
some_func('hello')
some_func(my_var='hello')