This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 0b680c9492 Revert "Provide the logger_name param in providers hooks in
order to override the logger name (#36675)" (#37015)
0b680c9492 is described below
commit 0b680c94922e3f7ca1f3ada8328e315bbae37dc8
Author: Andrey Anshin <andrey.ans...@taragol.is>
AuthorDate: Fri Jan 26 03:11:35 2024 +0400
Revert "Provide the logger_name param in providers hooks in order to
override the logger name (#36675)" (#37015)
This reverts commit 6bd450da1eb6cacc2ccfd4544d520ae059b75c3b.
---
airflow/providers/apache/beam/hooks/beam.py | 3 +--
airflow/providers/apache/druid/hooks/druid.py | 3 +--
airflow/providers/apache/hdfs/hooks/webhdfs.py | 4 ++--
airflow/providers/apache/hive/hooks/hive.py | 7 +++----
airflow/providers/apache/kafka/hooks/base.py | 2 +-
airflow/providers/apache/kylin/hooks/kylin.py | 3 +--
airflow/providers/apache/pig/hooks/pig.py | 7 ++-----
airflow/providers/apache/pinot/hooks/pinot.py | 3 +--
airflow/providers/apache/spark/hooks/spark_sql.py | 3 +--
airflow/providers/apprise/hooks/apprise.py | 4 ++--
airflow/providers/atlassian/jira/hooks/jira.py | 4 ++--
airflow/providers/cloudant/hooks/cloudant.py | 4 ++--
airflow/providers/cohere/hooks/cohere.py | 3 +--
airflow/providers/common/sql/hooks/sql.py | 2 +-
airflow/providers/databricks/hooks/databricks_base.py | 3 +--
airflow/providers/docker/hooks/docker.py | 3 +--
airflow/providers/elasticsearch/hooks/elasticsearch.py | 4 ++--
airflow/providers/facebook/ads/hooks/ads.py | 3 +--
airflow/providers/ftp/hooks/ftp.py | 4 ++--
airflow/providers/google/ads/hooks/ads.py | 3 +--
airflow/providers/google/cloud/hooks/cloud_sql.py | 3 +--
airflow/providers/google/cloud/hooks/dataprep.py | 4 ++--
airflow/providers/google/cloud/hooks/looker.py | 3 +--
airflow/providers/google/common/hooks/base_google.py | 4 +---
airflow/providers/google/leveldb/hooks/leveldb.py | 4 ++--
airflow/providers/grpc/hooks/grpc.py | 3 +--
airflow/providers/hashicorp/hooks/vault.py | 2 +-
airflow/providers/http/hooks/http.py | 5 +----
airflow/providers/imap/hooks/imap.py | 4 ++--
airflow/providers/jenkins/hooks/jenkins.py | 4 ++--
airflow/providers/microsoft/azure/hooks/adx.py | 4 ++--
airflow/providers/microsoft/azure/hooks/asb.py | 4 ++--
airflow/providers/microsoft/azure/hooks/base_azure.py | 4 ++--
airflow/providers/microsoft/azure/hooks/batch.py | 4 ++--
airflow/providers/microsoft/azure/hooks/container_registry.py | 4 ++--
airflow/providers/microsoft/azure/hooks/container_volume.py | 6 ++----
airflow/providers/microsoft/azure/hooks/cosmos.py | 4 ++--
airflow/providers/microsoft/azure/hooks/data_factory.py | 4 ++--
airflow/providers/microsoft/azure/hooks/data_lake.py | 8 ++++----
airflow/providers/microsoft/azure/hooks/fileshare.py | 3 +--
airflow/providers/microsoft/azure/hooks/synapse.py | 11 ++++-------
airflow/providers/microsoft/azure/hooks/wasb.py | 3 +--
airflow/providers/microsoft/psrp/hooks/psrp.py | 2 --
airflow/providers/microsoft/winrm/hooks/winrm.py | 3 +--
airflow/providers/mongo/hooks/mongo.py | 2 +-
airflow/providers/opsgenie/hooks/opsgenie.py | 4 ++--
airflow/providers/pagerduty/hooks/pagerduty.py | 4 ++--
airflow/providers/pagerduty/hooks/pagerduty_events.py | 7 ++-----
airflow/providers/pinecone/hooks/pinecone.py | 3 +--
airflow/providers/redis/hooks/redis.py | 4 ++--
airflow/providers/salesforce/hooks/salesforce.py | 3 +--
airflow/providers/samba/hooks/samba.py | 4 ++--
airflow/providers/segment/hooks/segment.py | 2 +-
airflow/providers/slack/hooks/slack.py | 2 +-
airflow/providers/slack/hooks/slack_webhook.py | 2 +-
airflow/providers/smtp/hooks/smtp.py | 4 ++--
airflow/providers/ssh/hooks/ssh.py | 3 +--
airflow/providers/tableau/hooks/tableau.py | 6 ++----
airflow/providers/tabular/hooks/tabular.py | 4 ++--
airflow/providers/telegram/hooks/telegram.py | 3 +--
airflow/providers/yandex/hooks/yandex.py | 3 +--
airflow/providers/zendesk/hooks/zendesk.py | 4 ++--
62 files changed, 97 insertions(+), 139 deletions(-)
diff --git a/airflow/providers/apache/beam/hooks/beam.py
b/airflow/providers/apache/beam/hooks/beam.py
index 548849dc40..29ecfa4651 100644
--- a/airflow/providers/apache/beam/hooks/beam.py
+++ b/airflow/providers/apache/beam/hooks/beam.py
@@ -183,10 +183,9 @@ class BeamHook(BaseHook):
def __init__(
self,
runner: str,
- **kwargs,
) -> None:
self.runner = runner
- super().__init__(**kwargs)
+ super().__init__()
def _start_pipeline(
self,
diff --git a/airflow/providers/apache/druid/hooks/druid.py
b/airflow/providers/apache/druid/hooks/druid.py
index 85bb1167fc..1c0f809247 100644
--- a/airflow/providers/apache/druid/hooks/druid.py
+++ b/airflow/providers/apache/druid/hooks/druid.py
@@ -60,9 +60,8 @@ class DruidHook(BaseHook):
druid_ingest_conn_id: str = "druid_ingest_default",
timeout: int = 1,
max_ingestion_time: int | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.druid_ingest_conn_id = druid_ingest_conn_id
self.timeout = timeout
self.max_ingestion_time = max_ingestion_time
diff --git a/airflow/providers/apache/hdfs/hooks/webhdfs.py
b/airflow/providers/apache/hdfs/hooks/webhdfs.py
index 8d907680a5..fdfdfc0c5a 100644
--- a/airflow/providers/apache/hdfs/hooks/webhdfs.py
+++ b/airflow/providers/apache/hdfs/hooks/webhdfs.py
@@ -57,8 +57,8 @@ class WebHDFSHook(BaseHook):
default_conn_name = "webhdfs_default"
hook_name = "Apache WebHDFS"
- def __init__(self, webhdfs_conn_id: str = default_conn_name, proxy_user:
str | None = None, **kwargs):
- super().__init__(**kwargs)
+ def __init__(self, webhdfs_conn_id: str = default_conn_name, proxy_user:
str | None = None):
+ super().__init__()
self.webhdfs_conn_id = webhdfs_conn_id
self.proxy_user = proxy_user
diff --git a/airflow/providers/apache/hive/hooks/hive.py
b/airflow/providers/apache/hive/hooks/hive.py
index 2fcb5e36c7..5bdaf8084c 100644
--- a/airflow/providers/apache/hive/hooks/hive.py
+++ b/airflow/providers/apache/hive/hooks/hive.py
@@ -98,9 +98,8 @@ class HiveCliHook(BaseHook):
hive_cli_params: str = "",
auth: str | None = None,
proxy_user: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
conn = self.get_connection(hive_cli_conn_id)
self.hive_cli_params: str = hive_cli_params
self.use_beeline: bool = conn.extra_dejson.get("use_beeline", False)
@@ -496,8 +495,8 @@ class HiveMetastoreHook(BaseHook):
conn_type = "hive_metastore"
hook_name = "Hive Metastore Thrift"
- def __init__(self, metastore_conn_id: str = default_conn_name, **kwargs)
-> None:
- super().__init__(**kwargs)
+ def __init__(self, metastore_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.conn = self.get_connection(metastore_conn_id)
self.metastore = self.get_metastore_client()
diff --git a/airflow/providers/apache/kafka/hooks/base.py
b/airflow/providers/apache/kafka/hooks/base.py
index 481fbcdc23..189c4cd2aa 100644
--- a/airflow/providers/apache/kafka/hooks/base.py
+++ b/airflow/providers/apache/kafka/hooks/base.py
@@ -38,7 +38,7 @@ class KafkaBaseHook(BaseHook):
def __init__(self, kafka_config_id=default_conn_name, *args, **kwargs):
"""Initialize our Base."""
- super().__init__(**kwargs)
+ super().__init__()
self.kafka_config_id = kafka_config_id
self.get_conn
diff --git a/airflow/providers/apache/kylin/hooks/kylin.py
b/airflow/providers/apache/kylin/hooks/kylin.py
index 959aa405e0..cfc2021f66 100644
--- a/airflow/providers/apache/kylin/hooks/kylin.py
+++ b/airflow/providers/apache/kylin/hooks/kylin.py
@@ -42,9 +42,8 @@ class KylinHook(BaseHook):
kylin_conn_id: str = default_conn_name,
project: str | None = None,
dsn: str | None = None,
- **kwargs,
):
- super().__init__(**kwargs)
+ super().__init__()
self.kylin_conn_id = kylin_conn_id
self.project = project
self.dsn = dsn
diff --git a/airflow/providers/apache/pig/hooks/pig.py
b/airflow/providers/apache/pig/hooks/pig.py
index 345c491855..ca6c2f022c 100644
--- a/airflow/providers/apache/pig/hooks/pig.py
+++ b/airflow/providers/apache/pig/hooks/pig.py
@@ -38,12 +38,9 @@ class PigCliHook(BaseHook):
hook_name = "Pig Client Wrapper"
def __init__(
- self,
- pig_cli_conn_id: str = default_conn_name,
- pig_properties: list[str] | None = None,
- **kwargs,
+ self, pig_cli_conn_id: str = default_conn_name, pig_properties:
list[str] | None = None
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
conn = self.get_connection(pig_cli_conn_id)
conn_pig_properties = conn.extra_dejson.get("pig_properties")
if conn_pig_properties:
diff --git a/airflow/providers/apache/pinot/hooks/pinot.py
b/airflow/providers/apache/pinot/hooks/pinot.py
index c915e19e56..3f89233fe6 100644
--- a/airflow/providers/apache/pinot/hooks/pinot.py
+++ b/airflow/providers/apache/pinot/hooks/pinot.py
@@ -68,9 +68,8 @@ class PinotAdminHook(BaseHook):
conn_id: str = "pinot_admin_default",
cmd_path: str = "pinot-admin.sh",
pinot_admin_system_exit: bool = False,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
conn = self.get_connection(conn_id)
self.host = conn.host
self.port = str(conn.port)
diff --git a/airflow/providers/apache/spark/hooks/spark_sql.py
b/airflow/providers/apache/spark/hooks/spark_sql.py
index 8c11ab68d2..46eec49f30 100644
--- a/airflow/providers/apache/spark/hooks/spark_sql.py
+++ b/airflow/providers/apache/spark/hooks/spark_sql.py
@@ -94,9 +94,8 @@ class SparkSqlHook(BaseHook):
num_executors: int | None = None,
verbose: bool = True,
yarn_queue: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
options: dict = {}
conn: Connection | None = None
diff --git a/airflow/providers/apprise/hooks/apprise.py
b/airflow/providers/apprise/hooks/apprise.py
index b420f9a890..48431e3bea 100644
--- a/airflow/providers/apprise/hooks/apprise.py
+++ b/airflow/providers/apprise/hooks/apprise.py
@@ -42,8 +42,8 @@ class AppriseHook(BaseHook):
conn_type = "apprise"
hook_name = "Apprise"
- def __init__(self, apprise_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, apprise_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.apprise_conn_id = apprise_conn_id
def get_config_from_conn(self):
diff --git a/airflow/providers/atlassian/jira/hooks/jira.py
b/airflow/providers/atlassian/jira/hooks/jira.py
index 0d6dc09a05..ed706aed95 100644
--- a/airflow/providers/atlassian/jira/hooks/jira.py
+++ b/airflow/providers/atlassian/jira/hooks/jira.py
@@ -39,8 +39,8 @@ class JiraHook(BaseHook):
conn_name_attr = "jira_conn_id"
hook_name = "JIRA"
- def __init__(self, jira_conn_id: str = default_conn_name, proxies: Any |
None = None, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, jira_conn_id: str = default_conn_name, proxies: Any |
None = None) -> None:
+ super().__init__()
self.jira_conn_id = jira_conn_id
self.proxies = proxies
self.client: Jira | None = None
diff --git a/airflow/providers/cloudant/hooks/cloudant.py
b/airflow/providers/cloudant/hooks/cloudant.py
index e57ce0080e..873462ccbf 100644
--- a/airflow/providers/cloudant/hooks/cloudant.py
+++ b/airflow/providers/cloudant/hooks/cloudant.py
@@ -48,8 +48,8 @@ class CloudantHook(BaseHook):
"relabeling": {"host": "Account", "login": "Username (or API
Key)", "schema": "Database"},
}
- def __init__(self, cloudant_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, cloudant_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.cloudant_conn_id = cloudant_conn_id
def get_conn(self) -> cloudant:
diff --git a/airflow/providers/cohere/hooks/cohere.py
b/airflow/providers/cohere/hooks/cohere.py
index e96c56052e..3b60c9060c 100644
--- a/airflow/providers/cohere/hooks/cohere.py
+++ b/airflow/providers/cohere/hooks/cohere.py
@@ -46,9 +46,8 @@ class CohereHook(BaseHook):
conn_id: str = default_conn_name,
timeout: int | None = None,
max_retries: int | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.conn_id = conn_id
self.timeout = timeout
self.max_retries = max_retries
diff --git a/airflow/providers/common/sql/hooks/sql.py
b/airflow/providers/common/sql/hooks/sql.py
index c300f167b1..ee3387a76c 100644
--- a/airflow/providers/common/sql/hooks/sql.py
+++ b/airflow/providers/common/sql/hooks/sql.py
@@ -148,7 +148,7 @@ class DbApiHook(BaseHook):
_test_connection_sql = "select 1"
def __init__(self, *args, schema: str | None = None, log_sql: bool = True,
**kwargs):
- super().__init__(logger_name=kwargs.pop("logger_name", None))
+ super().__init__()
if not self.conn_name_attr:
raise AirflowException("conn_name_attr is not defined")
elif len(args) == 1:
diff --git a/airflow/providers/databricks/hooks/databricks_base.py
b/airflow/providers/databricks/hooks/databricks_base.py
index e8d2b02bb2..dfbd464b5e 100644
--- a/airflow/providers/databricks/hooks/databricks_base.py
+++ b/airflow/providers/databricks/hooks/databricks_base.py
@@ -103,9 +103,8 @@ class BaseDatabricksHook(BaseHook):
retry_delay: float = 1.0,
retry_args: dict[Any, Any] | None = None,
caller: str = "Unknown",
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.databricks_conn_id = databricks_conn_id
self.timeout_seconds = timeout_seconds
if retry_limit < 1:
diff --git a/airflow/providers/docker/hooks/docker.py
b/airflow/providers/docker/hooks/docker.py
index f6596bc625..763c3a7877 100644
--- a/airflow/providers/docker/hooks/docker.py
+++ b/airflow/providers/docker/hooks/docker.py
@@ -64,9 +64,8 @@ class DockerHook(BaseHook):
version: str | None = None,
tls: TLSConfig | bool | None = None,
timeout: int = DEFAULT_TIMEOUT_SECONDS,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
if not base_url:
raise AirflowException("URL to the Docker server not provided.")
elif tls:
diff --git a/airflow/providers/elasticsearch/hooks/elasticsearch.py
b/airflow/providers/elasticsearch/hooks/elasticsearch.py
index 61e75c4adc..2d9fca4a97 100644
--- a/airflow/providers/elasticsearch/hooks/elasticsearch.py
+++ b/airflow/providers/elasticsearch/hooks/elasticsearch.py
@@ -164,8 +164,8 @@ class ElasticsearchPythonHook(BaseHook):
Example: {"ca_cert":"/path/to/cert",
"basic_auth": "(user, pass)"}
"""
- def __init__(self, hosts: list[Any], es_conn_args: dict | None = None,
**kwargs):
- super().__init__(**kwargs)
+ def __init__(self, hosts: list[Any], es_conn_args: dict | None = None):
+ super().__init__()
self.hosts = hosts
self.es_conn_args = es_conn_args or {}
diff --git a/airflow/providers/facebook/ads/hooks/ads.py
b/airflow/providers/facebook/ads/hooks/ads.py
index e7754f1287..b8b9c8526d 100644
--- a/airflow/providers/facebook/ads/hooks/ads.py
+++ b/airflow/providers/facebook/ads/hooks/ads.py
@@ -66,9 +66,8 @@ class FacebookAdsReportingHook(BaseHook):
self,
facebook_conn_id: str = default_conn_name,
api_version: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.facebook_conn_id = facebook_conn_id
self.api_version = api_version
self.client_required_fields = ["app_id", "app_secret", "access_token",
"account_id"]
diff --git a/airflow/providers/ftp/hooks/ftp.py
b/airflow/providers/ftp/hooks/ftp.py
index 6ec62f9665..54892da965 100644
--- a/airflow/providers/ftp/hooks/ftp.py
+++ b/airflow/providers/ftp/hooks/ftp.py
@@ -41,8 +41,8 @@ class FTPHook(BaseHook):
conn_type = "ftp"
hook_name = "FTP"
- def __init__(self, ftp_conn_id: str = default_conn_name, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, ftp_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.ftp_conn_id = ftp_conn_id
self.conn: ftplib.FTP | None = None
diff --git a/airflow/providers/google/ads/hooks/ads.py
b/airflow/providers/google/ads/hooks/ads.py
index 1f9b04ec09..822efe5dfc 100644
--- a/airflow/providers/google/ads/hooks/ads.py
+++ b/airflow/providers/google/ads/hooks/ads.py
@@ -79,9 +79,8 @@ class GoogleAdsHook(BaseHook):
api_version: str | None,
gcp_conn_id: str = "google_cloud_default",
google_ads_conn_id: str = "google_ads_default",
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.api_version = api_version or self.default_api_version
self.gcp_conn_id = gcp_conn_id
self.google_ads_conn_id = google_ads_conn_id
diff --git a/airflow/providers/google/cloud/hooks/cloud_sql.py
b/airflow/providers/google/cloud/hooks/cloud_sql.py
index 597e5442f2..6e8f7774fc 100644
--- a/airflow/providers/google/cloud/hooks/cloud_sql.py
+++ b/airflow/providers/google/cloud/hooks/cloud_sql.py
@@ -771,9 +771,8 @@ class CloudSQLDatabaseHook(BaseHook):
gcp_conn_id: str = "google_cloud_default",
default_gcp_project_id: str | None = None,
sql_proxy_binary_path: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.gcp_conn_id = gcp_conn_id
self.gcp_cloudsql_conn_id = gcp_cloudsql_conn_id
self.cloudsql_connection =
self.get_connection(self.gcp_cloudsql_conn_id)
diff --git a/airflow/providers/google/cloud/hooks/dataprep.py
b/airflow/providers/google/cloud/hooks/dataprep.py
index 6b6cee61ce..9e006fa99f 100644
--- a/airflow/providers/google/cloud/hooks/dataprep.py
+++ b/airflow/providers/google/cloud/hooks/dataprep.py
@@ -72,8 +72,8 @@ class GoogleDataprepHook(BaseHook):
conn_type = "dataprep"
hook_name = "Google Dataprep"
- def __init__(self, dataprep_conn_id: str = default_conn_name, api_version:
str = "v4", **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, dataprep_conn_id: str = default_conn_name, api_version:
str = "v4") -> None:
+ super().__init__()
self.dataprep_conn_id = dataprep_conn_id
self.api_version = api_version
conn = self.get_connection(self.dataprep_conn_id)
diff --git a/airflow/providers/google/cloud/hooks/looker.py
b/airflow/providers/google/cloud/hooks/looker.py
index 945297cd47..cd725b9f21 100644
--- a/airflow/providers/google/cloud/hooks/looker.py
+++ b/airflow/providers/google/cloud/hooks/looker.py
@@ -41,9 +41,8 @@ class LookerHook(BaseHook):
def __init__(
self,
looker_conn_id: str,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.looker_conn_id = looker_conn_id
# source is used to track origin of the requests
self.source = f"airflow:{version}"
diff --git a/airflow/providers/google/common/hooks/base_google.py
b/airflow/providers/google/common/hooks/base_google.py
index b160a2e2b2..ccce50d896 100644
--- a/airflow/providers/google/common/hooks/base_google.py
+++ b/airflow/providers/google/common/hooks/base_google.py
@@ -239,9 +239,8 @@ class GoogleBaseHook(BaseHook):
gcp_conn_id: str = "google_cloud_default",
delegate_to: str | None = None,
impersonation_chain: str | Sequence[str] | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.gcp_conn_id = gcp_conn_id
self.delegate_to = delegate_to
self.impersonation_chain = impersonation_chain
@@ -682,7 +681,6 @@ class GoogleBaseAsyncHook(BaseHook):
sync_hook_class: Any = None
def __init__(self, **kwargs: Any):
- super().__init__(logger_name=kwargs.pop("logger_name", None))
self._hook_kwargs = kwargs
self._sync_hook = None
diff --git a/airflow/providers/google/leveldb/hooks/leveldb.py
b/airflow/providers/google/leveldb/hooks/leveldb.py
index 9b5002fb3e..16d2773bad 100644
--- a/airflow/providers/google/leveldb/hooks/leveldb.py
+++ b/airflow/providers/google/leveldb/hooks/leveldb.py
@@ -45,8 +45,8 @@ class LevelDBHook(BaseHook):
conn_type = "leveldb"
hook_name = "LevelDB"
- def __init__(self, leveldb_conn_id: str = default_conn_name, **kwargs):
- super().__init__(**kwargs)
+ def __init__(self, leveldb_conn_id: str = default_conn_name):
+ super().__init__()
self.leveldb_conn_id = leveldb_conn_id
self.connection = self.get_connection(leveldb_conn_id)
self.db: plyvel.DB | None = None
diff --git a/airflow/providers/grpc/hooks/grpc.py
b/airflow/providers/grpc/hooks/grpc.py
index d67c1fe166..a6a3ca1271 100644
--- a/airflow/providers/grpc/hooks/grpc.py
+++ b/airflow/providers/grpc/hooks/grpc.py
@@ -71,9 +71,8 @@ class GrpcHook(BaseHook):
grpc_conn_id: str = default_conn_name,
interceptors: list[Callable] | None = None,
custom_connection_func: Callable | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.grpc_conn_id = grpc_conn_id
self.conn = self.get_connection(self.grpc_conn_id)
self.extras = self.conn.extra_dejson
diff --git a/airflow/providers/hashicorp/hooks/vault.py
b/airflow/providers/hashicorp/hooks/vault.py
index 162834c7fa..4edf616652 100644
--- a/airflow/providers/hashicorp/hooks/vault.py
+++ b/airflow/providers/hashicorp/hooks/vault.py
@@ -125,7 +125,7 @@ class VaultHook(BaseHook):
radius_port: int | None = None,
**kwargs,
):
- super().__init__(logger_name=kwargs.pop("logger_name", None))
+ super().__init__()
self.connection = self.get_connection(vault_conn_id)
if not auth_type:
diff --git a/airflow/providers/http/hooks/http.py
b/airflow/providers/http/hooks/http.py
index 7b98ec25df..8ba5d08ab3 100644
--- a/airflow/providers/http/hooks/http.py
+++ b/airflow/providers/http/hooks/http.py
@@ -68,9 +68,8 @@ class HttpHook(BaseHook):
tcp_keep_alive_idle: int = 120,
tcp_keep_alive_count: int = 20,
tcp_keep_alive_interval: int = 30,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.http_conn_id = http_conn_id
self.method = method.upper()
self.base_url: str = ""
@@ -298,9 +297,7 @@ class HttpAsyncHook(BaseHook):
auth_type: Any = aiohttp.BasicAuth,
retry_limit: int = 3,
retry_delay: float = 1.0,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
self.http_conn_id = http_conn_id
self.method = method.upper()
self.base_url: str = ""
diff --git a/airflow/providers/imap/hooks/imap.py
b/airflow/providers/imap/hooks/imap.py
index f00da812b9..1ff2c7154b 100644
--- a/airflow/providers/imap/hooks/imap.py
+++ b/airflow/providers/imap/hooks/imap.py
@@ -53,8 +53,8 @@ class ImapHook(BaseHook):
conn_type = "imap"
hook_name = "IMAP"
- def __init__(self, imap_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, imap_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.imap_conn_id = imap_conn_id
self.mail_client: imaplib.IMAP4_SSL | imaplib.IMAP4 | None = None
diff --git a/airflow/providers/jenkins/hooks/jenkins.py
b/airflow/providers/jenkins/hooks/jenkins.py
index 043f1a188d..afdde319a8 100644
--- a/airflow/providers/jenkins/hooks/jenkins.py
+++ b/airflow/providers/jenkins/hooks/jenkins.py
@@ -59,8 +59,8 @@ class JenkinsHook(BaseHook):
},
}
- def __init__(self, conn_id: str = default_conn_name, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, conn_id: str = default_conn_name) -> None:
+ super().__init__()
connection = self.get_connection(conn_id)
self.connection = connection
connection_prefix = "http"
diff --git a/airflow/providers/microsoft/azure/hooks/adx.py
b/airflow/providers/microsoft/azure/hooks/adx.py
index 5cefc7c888..bbe46c4a1f 100644
--- a/airflow/providers/microsoft/azure/hooks/adx.py
+++ b/airflow/providers/microsoft/azure/hooks/adx.py
@@ -120,8 +120,8 @@ class AzureDataExplorerHook(BaseHook):
},
}
- def __init__(self, azure_data_explorer_conn_id: str = default_conn_name,
**kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_data_explorer_conn_id: str = default_conn_name)
-> None:
+ super().__init__()
self.conn_id = azure_data_explorer_conn_id
@cached_property
diff --git a/airflow/providers/microsoft/azure/hooks/asb.py
b/airflow/providers/microsoft/azure/hooks/asb.py
index e9dc3776de..6155165554 100644
--- a/airflow/providers/microsoft/azure/hooks/asb.py
+++ b/airflow/providers/microsoft/azure/hooks/asb.py
@@ -75,8 +75,8 @@ class BaseAzureServiceBusHook(BaseHook):
},
}
- def __init__(self, azure_service_bus_conn_id: str = default_conn_name,
**kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_service_bus_conn_id: str = default_conn_name) ->
None:
+ super().__init__()
self.conn_id = azure_service_bus_conn_id
def get_conn(self):
diff --git a/airflow/providers/microsoft/azure/hooks/base_azure.py
b/airflow/providers/microsoft/azure/hooks/base_azure.py
index d77376ba03..9ec7aedd4b 100644
--- a/airflow/providers/microsoft/azure/hooks/base_azure.py
+++ b/airflow/providers/microsoft/azure/hooks/base_azure.py
@@ -86,10 +86,10 @@ class AzureBaseHook(BaseHook):
},
}
- def __init__(self, sdk_client: Any, conn_id: str = "azure_default",
**kwargs):
+ def __init__(self, sdk_client: Any, conn_id: str = "azure_default"):
self.sdk_client = sdk_client
self.conn_id = conn_id
- super().__init__(**kwargs)
+ super().__init__()
def get_conn(self) -> Any:
"""
diff --git a/airflow/providers/microsoft/azure/hooks/batch.py
b/airflow/providers/microsoft/azure/hooks/batch.py
index 2d26cc9f03..f65b97f5a1 100644
--- a/airflow/providers/microsoft/azure/hooks/batch.py
+++ b/airflow/providers/microsoft/azure/hooks/batch.py
@@ -73,8 +73,8 @@ class AzureBatchHook(BaseHook):
},
}
- def __init__(self, azure_batch_conn_id: str = default_conn_name, **kwargs)
-> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_batch_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.conn_id = azure_batch_conn_id
def _get_field(self, extras, name):
diff --git a/airflow/providers/microsoft/azure/hooks/container_registry.py
b/airflow/providers/microsoft/azure/hooks/container_registry.py
index 4c8c3c4061..acc704dfdf 100644
--- a/airflow/providers/microsoft/azure/hooks/container_registry.py
+++ b/airflow/providers/microsoft/azure/hooks/container_registry.py
@@ -84,8 +84,8 @@ class AzureContainerRegistryHook(BaseHook):
},
}
- def __init__(self, conn_id: str = "azure_registry", **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, conn_id: str = "azure_registry") -> None:
+ super().__init__()
self.conn_id = conn_id
def _get_field(self, extras, name):
diff --git a/airflow/providers/microsoft/azure/hooks/container_volume.py
b/airflow/providers/microsoft/azure/hooks/container_volume.py
index 1e253404ce..5fa926bc1b 100644
--- a/airflow/providers/microsoft/azure/hooks/container_volume.py
+++ b/airflow/providers/microsoft/azure/hooks/container_volume.py
@@ -83,10 +83,8 @@ class AzureContainerVolumeHook(BaseHook):
},
}
- def __init__(
- self, azure_container_volume_conn_id: str =
"azure_container_volume_default", **kwargs
- ) -> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_container_volume_conn_id: str =
"azure_container_volume_default") -> None:
+ super().__init__()
self.conn_id = azure_container_volume_conn_id
def _get_field(self, extras, name):
diff --git a/airflow/providers/microsoft/azure/hooks/cosmos.py
b/airflow/providers/microsoft/azure/hooks/cosmos.py
index fef2ead2e4..cf56924609 100644
--- a/airflow/providers/microsoft/azure/hooks/cosmos.py
+++ b/airflow/providers/microsoft/azure/hooks/cosmos.py
@@ -103,8 +103,8 @@ class AzureCosmosDBHook(BaseHook):
},
}
- def __init__(self, azure_cosmos_conn_id: str = default_conn_name,
**kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_cosmos_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.conn_id = azure_cosmos_conn_id
self._conn: CosmosClient | None = None
diff --git a/airflow/providers/microsoft/azure/hooks/data_factory.py
b/airflow/providers/microsoft/azure/hooks/data_factory.py
index 41d8888417..83181e89c0 100644
--- a/airflow/providers/microsoft/azure/hooks/data_factory.py
+++ b/airflow/providers/microsoft/azure/hooks/data_factory.py
@@ -184,10 +184,10 @@ class AzureDataFactoryHook(BaseHook):
},
}
- def __init__(self, azure_data_factory_conn_id: str = default_conn_name,
**kwargs):
+ def __init__(self, azure_data_factory_conn_id: str = default_conn_name):
self._conn: DataFactoryManagementClient | None = None
self.conn_id = azure_data_factory_conn_id
- super().__init__(**kwargs)
+ super().__init__()
def get_conn(self) -> DataFactoryManagementClient:
if self._conn is not None:
diff --git a/airflow/providers/microsoft/azure/hooks/data_lake.py
b/airflow/providers/microsoft/azure/hooks/data_lake.py
index f69dd8d8ea..0b247ac7fc 100644
--- a/airflow/providers/microsoft/azure/hooks/data_lake.py
+++ b/airflow/providers/microsoft/azure/hooks/data_lake.py
@@ -97,8 +97,8 @@ class AzureDataLakeHook(BaseHook):
},
}
- def __init__(self, azure_data_lake_conn_id: str = default_conn_name,
**kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, azure_data_lake_conn_id: str = default_conn_name) ->
None:
+ super().__init__()
self.conn_id = azure_data_lake_conn_id
self._conn: core.AzureDLFileSystem | None = None
self.account_name: str | None = None
@@ -311,8 +311,8 @@ class AzureDataLakeStorageV2Hook(BaseHook):
},
}
- def __init__(self, adls_conn_id: str, public_read: bool = False, **kwargs)
-> None:
- super().__init__(**kwargs)
+ def __init__(self, adls_conn_id: str, public_read: bool = False) -> None:
+ super().__init__()
self.conn_id = adls_conn_id
self.public_read = public_read
diff --git a/airflow/providers/microsoft/azure/hooks/fileshare.py
b/airflow/providers/microsoft/azure/hooks/fileshare.py
index 5b52ffbe02..a051dbadad 100644
--- a/airflow/providers/microsoft/azure/hooks/fileshare.py
+++ b/airflow/providers/microsoft/azure/hooks/fileshare.py
@@ -80,9 +80,8 @@ class AzureFileShareHook(BaseHook):
file_path: str | None = None,
directory_path: str | None = None,
azure_fileshare_conn_id: str = "azure_fileshare_default",
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self._conn_id = azure_fileshare_conn_id
self.share_name = share_name
self.file_path = file_path
diff --git a/airflow/providers/microsoft/azure/hooks/synapse.py
b/airflow/providers/microsoft/azure/hooks/synapse.py
index 8e7e662cdc..397c82640d 100644
--- a/airflow/providers/microsoft/azure/hooks/synapse.py
+++ b/airflow/providers/microsoft/azure/hooks/synapse.py
@@ -94,12 +94,12 @@ class AzureSynapseHook(BaseHook):
},
}
- def __init__(self, azure_synapse_conn_id: str = default_conn_name,
spark_pool: str = "", **kwargs):
+ def __init__(self, azure_synapse_conn_id: str = default_conn_name,
spark_pool: str = ""):
self.job_id: int | None = None
self._conn: SparkClient | None = None
self.conn_id = azure_synapse_conn_id
self.spark_pool = spark_pool
- super().__init__(**kwargs)
+ super().__init__()
def _get_field(self, extras, name):
return get_field(
@@ -273,15 +273,12 @@ class AzureSynapsePipelineHook(BaseHook):
}
def __init__(
- self,
- azure_synapse_workspace_dev_endpoint: str,
- azure_synapse_conn_id: str = default_conn_name,
- **kwargs,
+ self, azure_synapse_workspace_dev_endpoint: str,
azure_synapse_conn_id: str = default_conn_name
):
self._conn = None
self.conn_id = azure_synapse_conn_id
self.azure_synapse_workspace_dev_endpoint =
azure_synapse_workspace_dev_endpoint
- super().__init__(**kwargs)
+ super().__init__()
def _get_field(self, extras, name):
return get_field(
diff --git a/airflow/providers/microsoft/azure/hooks/wasb.py
b/airflow/providers/microsoft/azure/hooks/wasb.py
index ea0318b910..7d05ac862b 100644
--- a/airflow/providers/microsoft/azure/hooks/wasb.py
+++ b/airflow/providers/microsoft/azure/hooks/wasb.py
@@ -128,9 +128,8 @@ class WasbHook(BaseHook):
self,
wasb_conn_id: str = default_conn_name,
public_read: bool = False,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.conn_id = wasb_conn_id
self.public_read = public_read
diff --git a/airflow/providers/microsoft/psrp/hooks/psrp.py
b/airflow/providers/microsoft/psrp/hooks/psrp.py
index df0a766dbd..d77e73c278 100644
--- a/airflow/providers/microsoft/psrp/hooks/psrp.py
+++ b/airflow/providers/microsoft/psrp/hooks/psrp.py
@@ -88,9 +88,7 @@ class PsrpHook(BaseHook):
on_output_callback: OutputCallback | None = None,
exchange_keys: bool = True,
host: PSHost | None = None,
- **kwargs,
):
- super().__init__(**kwargs)
self.conn_id = psrp_conn_id
self._logging_level = logging_level
self._operation_timeout = operation_timeout
diff --git a/airflow/providers/microsoft/winrm/hooks/winrm.py
b/airflow/providers/microsoft/winrm/hooks/winrm.py
index e25bed7e39..b8a2b56d46 100644
--- a/airflow/providers/microsoft/winrm/hooks/winrm.py
+++ b/airflow/providers/microsoft/winrm/hooks/winrm.py
@@ -90,9 +90,8 @@ class WinRMHook(BaseHook):
message_encryption: str | None = "auto",
credssp_disable_tlsv1_2: bool = False,
send_cbt: bool = True,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.ssh_conn_id = ssh_conn_id
self.endpoint = endpoint
self.remote_host = remote_host
diff --git a/airflow/providers/mongo/hooks/mongo.py
b/airflow/providers/mongo/hooks/mongo.py
index 9eacfb6817..f883a33ad6 100644
--- a/airflow/providers/mongo/hooks/mongo.py
+++ b/airflow/providers/mongo/hooks/mongo.py
@@ -60,7 +60,7 @@ class MongoHook(BaseHook):
hook_name = "MongoDB"
def __init__(self, mongo_conn_id: str = default_conn_name, *args,
**kwargs) -> None:
- super().__init__(logger_name=kwargs.pop("logger_name", None))
+ super().__init__()
if conn_id := kwargs.pop("conn_id", None):
warnings.warn(
"Parameter `conn_id` is deprecated and will be removed in a
future releases. "
diff --git a/airflow/providers/opsgenie/hooks/opsgenie.py
b/airflow/providers/opsgenie/hooks/opsgenie.py
index 3a807b1440..8dab4e12e5 100644
--- a/airflow/providers/opsgenie/hooks/opsgenie.py
+++ b/airflow/providers/opsgenie/hooks/opsgenie.py
@@ -52,8 +52,8 @@ class OpsgenieAlertHook(BaseHook):
conn_type = "opsgenie"
hook_name = "Opsgenie"
- def __init__(self, opsgenie_conn_id: str = "opsgenie_default", **kwargs)
-> None:
- super().__init__(**kwargs) # type: ignore[misc]
+ def __init__(self, opsgenie_conn_id: str = "opsgenie_default") -> None:
+ super().__init__() # type: ignore[misc]
self.conn_id = opsgenie_conn_id
configuration = Configuration()
conn = self.get_connection(self.conn_id)
diff --git a/airflow/providers/pagerduty/hooks/pagerduty.py
b/airflow/providers/pagerduty/hooks/pagerduty.py
index 0d837150bf..82ef03eb40 100644
--- a/airflow/providers/pagerduty/hooks/pagerduty.py
+++ b/airflow/providers/pagerduty/hooks/pagerduty.py
@@ -77,8 +77,8 @@ class PagerdutyHook(BaseHook):
),
}
- def __init__(self, token: str | None = None, pagerduty_conn_id: str | None
= None, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, token: str | None = None, pagerduty_conn_id: str | None
= None) -> None:
+ super().__init__()
self.routing_key = None
self._session = None
diff --git a/airflow/providers/pagerduty/hooks/pagerduty_events.py
b/airflow/providers/pagerduty/hooks/pagerduty_events.py
index cfa8df30be..0a3fa3727d 100644
--- a/airflow/providers/pagerduty/hooks/pagerduty_events.py
+++ b/airflow/providers/pagerduty/hooks/pagerduty_events.py
@@ -58,12 +58,9 @@ class PagerdutyEventsHook(BaseHook):
}
def __init__(
- self,
- integration_key: str | None = None,
- pagerduty_events_conn_id: str | None = None,
- **kwargs,
+ self, integration_key: str | None = None, pagerduty_events_conn_id:
str | None = None
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.integration_key = None
self._session = None
diff --git a/airflow/providers/pinecone/hooks/pinecone.py
b/airflow/providers/pinecone/hooks/pinecone.py
index d8f73771d5..f15605556c 100644
--- a/airflow/providers/pinecone/hooks/pinecone.py
+++ b/airflow/providers/pinecone/hooks/pinecone.py
@@ -66,8 +66,7 @@ class PineconeHook(BaseHook):
"relabeling": {"login": "Pinecone Environment", "password":
"Pinecone API key"},
}
- def __init__(self, conn_id: str = default_conn_name, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, conn_id: str = default_conn_name) -> None:
self.conn_id = conn_id
self.get_conn()
diff --git a/airflow/providers/redis/hooks/redis.py
b/airflow/providers/redis/hooks/redis.py
index 157614f001..a481dbe565 100644
--- a/airflow/providers/redis/hooks/redis.py
+++ b/airflow/providers/redis/hooks/redis.py
@@ -44,14 +44,14 @@ class RedisHook(BaseHook):
conn_type = "redis"
hook_name = "Redis"
- def __init__(self, redis_conn_id: str = default_conn_name, **kwargs) ->
None:
+ def __init__(self, redis_conn_id: str = default_conn_name) -> None:
"""
Prepares hook to connect to a Redis database.
:param conn_id: the name of the connection that has the parameters
we need to connect to Redis.
"""
- super().__init__(**kwargs)
+ super().__init__()
self.redis_conn_id = redis_conn_id
self.redis = None
self.host = None
diff --git a/airflow/providers/salesforce/hooks/salesforce.py
b/airflow/providers/salesforce/hooks/salesforce.py
index 3dd47f1c36..af3ef1292b 100644
--- a/airflow/providers/salesforce/hooks/salesforce.py
+++ b/airflow/providers/salesforce/hooks/salesforce.py
@@ -72,9 +72,8 @@ class SalesforceHook(BaseHook):
salesforce_conn_id: str = default_conn_name,
session_id: str | None = None,
session: Session | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.conn_id = salesforce_conn_id
self.session_id = session_id
self.session = session
diff --git a/airflow/providers/samba/hooks/samba.py
b/airflow/providers/samba/hooks/samba.py
index ca0d478bbb..e4745be6ce 100644
--- a/airflow/providers/samba/hooks/samba.py
+++ b/airflow/providers/samba/hooks/samba.py
@@ -47,8 +47,8 @@ class SambaHook(BaseHook):
conn_type = "samba"
hook_name = "Samba"
- def __init__(self, samba_conn_id: str = default_conn_name, share: str |
None = None, **kwargs) -> None:
- super().__init__(**kwargs)
+ def __init__(self, samba_conn_id: str = default_conn_name, share: str |
None = None) -> None:
+ super().__init__()
conn = self.get_connection(samba_conn_id)
if not conn.login:
diff --git a/airflow/providers/segment/hooks/segment.py
b/airflow/providers/segment/hooks/segment.py
index 392d14a683..258716387d 100644
--- a/airflow/providers/segment/hooks/segment.py
+++ b/airflow/providers/segment/hooks/segment.py
@@ -57,7 +57,7 @@ class SegmentHook(BaseHook):
def __init__(
self, segment_conn_id: str = "segment_default", segment_debug_mode:
bool = False, *args, **kwargs
) -> None:
- super().__init__(kwargs.pop("logger_name", None))
+ super().__init__()
self.segment_conn_id = segment_conn_id
self.segment_debug_mode = segment_debug_mode
self._args = args
diff --git a/airflow/providers/slack/hooks/slack.py
b/airflow/providers/slack/hooks/slack.py
index b25282f370..12d02da748 100644
--- a/airflow/providers/slack/hooks/slack.py
+++ b/airflow/providers/slack/hooks/slack.py
@@ -114,7 +114,7 @@ class SlackHook(BaseHook):
retry_handlers: list[RetryHandler] | None = None,
**extra_client_args: Any,
) -> None:
- super().__init__(logger_name=extra_client_args.pop("logger_name",
None))
+ super().__init__()
self.slack_conn_id = slack_conn_id
self.base_url = base_url
self.timeout = timeout
diff --git a/airflow/providers/slack/hooks/slack_webhook.py
b/airflow/providers/slack/hooks/slack_webhook.py
index a36dcbde28..fcf25e44aa 100644
--- a/airflow/providers/slack/hooks/slack_webhook.py
+++ b/airflow/providers/slack/hooks/slack_webhook.py
@@ -111,7 +111,7 @@ class SlackWebhookHook(BaseHook):
retry_handlers: list[RetryHandler] | None = None,
**extra_client_args: Any,
):
- super().__init__(logger_name=extra_client_args.pop("logger_name",
None))
+ super().__init__()
self.slack_webhook_conn_id = slack_webhook_conn_id
self.timeout = timeout
self.proxy = proxy
diff --git a/airflow/providers/smtp/hooks/smtp.py
b/airflow/providers/smtp/hooks/smtp.py
index b6638c9a67..4712180eac 100644
--- a/airflow/providers/smtp/hooks/smtp.py
+++ b/airflow/providers/smtp/hooks/smtp.py
@@ -56,8 +56,8 @@ class SmtpHook(BaseHook):
conn_type = "smtp"
hook_name = "SMTP"
- def __init__(self, smtp_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, smtp_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.smtp_conn_id = smtp_conn_id
self.smtp_connection: Connection | None = None
self.smtp_client: smtplib.SMTP_SSL | smtplib.SMTP | None = None
diff --git a/airflow/providers/ssh/hooks/ssh.py
b/airflow/providers/ssh/hooks/ssh.py
index 79a6f23ae3..db69cd53e5 100644
--- a/airflow/providers/ssh/hooks/ssh.py
+++ b/airflow/providers/ssh/hooks/ssh.py
@@ -118,9 +118,8 @@ class SSHHook(BaseHook):
banner_timeout: float = 30.0,
disabled_algorithms: dict | None = None,
ciphers: list[str] | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.ssh_conn_id = ssh_conn_id
self.remote_host = remote_host
self.username = username
diff --git a/airflow/providers/tableau/hooks/tableau.py
b/airflow/providers/tableau/hooks/tableau.py
index cd865aa408..a02b997d81 100644
--- a/airflow/providers/tableau/hooks/tableau.py
+++ b/airflow/providers/tableau/hooks/tableau.py
@@ -80,10 +80,8 @@ class TableauHook(BaseHook):
conn_type = "tableau"
hook_name = "Tableau"
- def __init__(
- self, site_id: str | None = None, tableau_conn_id: str =
default_conn_name, **kwargs
- ) -> None:
- super().__init__(**kwargs)
+ def __init__(self, site_id: str | None = None, tableau_conn_id: str =
default_conn_name) -> None:
+ super().__init__()
self.tableau_conn_id = tableau_conn_id
self.conn = self.get_connection(self.tableau_conn_id)
self.site_id = site_id or self.conn.extra_dejson.get("site_id", "")
diff --git a/airflow/providers/tabular/hooks/tabular.py
b/airflow/providers/tabular/hooks/tabular.py
index 9fd408581d..3d0835282e 100644
--- a/airflow/providers/tabular/hooks/tabular.py
+++ b/airflow/providers/tabular/hooks/tabular.py
@@ -61,8 +61,8 @@ class TabularHook(BaseHook):
},
}
- def __init__(self, tabular_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, tabular_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.conn_id = tabular_conn_id
def test_connection(self) -> tuple[bool, str]:
diff --git a/airflow/providers/telegram/hooks/telegram.py
b/airflow/providers/telegram/hooks/telegram.py
index 47a5e070dd..984f18a1ba 100644
--- a/airflow/providers/telegram/hooks/telegram.py
+++ b/airflow/providers/telegram/hooks/telegram.py
@@ -63,9 +63,8 @@ class TelegramHook(BaseHook):
telegram_conn_id: str | None = None,
token: str | None = None,
chat_id: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
self.token = self.__get_token(token, telegram_conn_id)
self.chat_id = self.__get_chat_id(chat_id, telegram_conn_id)
self.connection = self.get_conn()
diff --git a/airflow/providers/yandex/hooks/yandex.py
b/airflow/providers/yandex/hooks/yandex.py
index 67afc2d59f..d76fbc7182 100644
--- a/airflow/providers/yandex/hooks/yandex.py
+++ b/airflow/providers/yandex/hooks/yandex.py
@@ -121,9 +121,8 @@ class YandexCloudBaseHook(BaseHook):
default_folder_id: str | None = None,
default_public_ssh_key: str | None = None,
default_service_account_id: str | None = None,
- **kwargs,
) -> None:
- super().__init__(**kwargs)
+ super().__init__()
if connection_id:
warnings.warn(
"Using `connection_id` is deprecated. Please use
`yandex_conn_id` parameter.",
diff --git a/airflow/providers/zendesk/hooks/zendesk.py
b/airflow/providers/zendesk/hooks/zendesk.py
index 40671a2e4f..00ff3b94f0 100644
--- a/airflow/providers/zendesk/hooks/zendesk.py
+++ b/airflow/providers/zendesk/hooks/zendesk.py
@@ -48,8 +48,8 @@ class ZendeskHook(BaseHook):
"relabeling": {"host": "Zendesk domain", "login": "Zendesk email"},
}
- def __init__(self, zendesk_conn_id: str = default_conn_name, **kwargs) ->
None:
- super().__init__(**kwargs)
+ def __init__(self, zendesk_conn_id: str = default_conn_name) -> None:
+ super().__init__()
self.zendesk_conn_id = zendesk_conn_id
self.base_api: BaseApi | None = None
zenpy_client, url = self._init_conn()
