From 87ab8d310829a7c96e19f03e1142328a949d8a50 Mon Sep 17 00:00:00 2001 From: rohithreddykota Date: Mon, 24 Mar 2025 16:44:15 -0400 Subject: [PATCH] fix: MRO Issue in operator/clickhouse_dbapi --- .../operators/clickhouse_dbapi.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/airflow_clickhouse_plugin/operators/clickhouse_dbapi.py b/src/airflow_clickhouse_plugin/operators/clickhouse_dbapi.py index de8c611..eb8a47a 100644 --- a/src/airflow_clickhouse_plugin/operators/clickhouse_dbapi.py +++ b/src/airflow_clickhouse_plugin/operators/clickhouse_dbapi.py @@ -27,56 +27,56 @@ def get_db_hook(self) -> ClickHouseDbApiHook: class ClickHouseSQLExecuteQueryOperator( - ClickHouseBaseDbApiOperator, sql.SQLExecuteQueryOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLColumnCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLColumnCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLTableCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLTableCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLValueCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLValueCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLIntervalCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLIntervalCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseSQLThresholdCheckOperator( - ClickHouseBaseDbApiOperator, sql.SQLThresholdCheckOperator, + ClickHouseBaseDbApiOperator, ): pass class ClickHouseBranchSQLOperator( - ClickHouseBaseDbApiOperator, sql.BranchSQLOperator, + ClickHouseBaseDbApiOperator, ): pass