From 7462c691f03bf054b355b774a42a7fd04ff741da Mon Sep 17 00:00:00 2001 From: Andrey Anshin Date: Thu, 25 Jan 2024 22:40:56 +0400 Subject: [PATCH] Revert "Provide the logger_name param in providers hooks in order to override the logger name (#36675)" 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 +-- .../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 ++-- .../microsoft/azure/hooks/container_registry.py | 4 ++-- .../microsoft/azure/hooks/container_volume.py | 6 ++---- airflow/providers/microsoft/azure/hooks/cosmos.py | 4 ++-- .../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 548849dc40b09..29ecfa46516c0 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 85bb1167fc91c..1c0f809247b49 100644 --- a/airflow/providers/apache/druid/hooks/druid.py +++ b/airflow/providers/apache/druid/hooks/druid.py @@ -60,9 +60,8 @@ def __init__( 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 8d907680a5c7e..fdfdfc0c5a49e 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 2fcb5e36c7771..5bdaf8084cb86 100644 --- a/airflow/providers/apache/hive/hooks/hive.py +++ b/airflow/providers/apache/hive/hooks/hive.py @@ -98,9 +98,8 @@ def __init__( 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 481fbcdc23473..189c4cd2aafde 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 959aa405e0367..cfc2021f66069 100644 --- a/airflow/providers/apache/kylin/hooks/kylin.py +++ b/airflow/providers/apache/kylin/hooks/kylin.py @@ -42,9 +42,8 @@ def __init__( 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 345c491855e28..ca6c2f022c70f 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 c915e19e568df..3f89233fe6a3b 100644 --- a/airflow/providers/apache/pinot/hooks/pinot.py +++ b/airflow/providers/apache/pinot/hooks/pinot.py @@ -68,9 +68,8 @@ def __init__( 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 8c11ab68d2876..46eec49f30131 100644 --- a/airflow/providers/apache/spark/hooks/spark_sql.py +++ b/airflow/providers/apache/spark/hooks/spark_sql.py @@ -94,9 +94,8 @@ def __init__( 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 b420f9a890040..48431e3beaf7d 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 0d6dc09a05fee..ed706aed958ce 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 e57ce0080e0d3..873462ccbf663 100644 --- a/airflow/providers/cloudant/hooks/cloudant.py +++ b/airflow/providers/cloudant/hooks/cloudant.py @@ -48,8 +48,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: "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 e96c56052e99a..3b60c9060c361 100644 --- a/airflow/providers/cohere/hooks/cohere.py +++ b/airflow/providers/cohere/hooks/cohere.py @@ -46,9 +46,8 @@ def __init__( 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 c300f167b10a0..ee3387a76c1cf 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 e8d2b02bb2b39..dfbd464b5ee62 100644 --- a/airflow/providers/databricks/hooks/databricks_base.py +++ b/airflow/providers/databricks/hooks/databricks_base.py @@ -103,9 +103,8 @@ def __init__( 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 f6596bc62578d..763c3a787744b 100644 --- a/airflow/providers/docker/hooks/docker.py +++ b/airflow/providers/docker/hooks/docker.py @@ -64,9 +64,8 @@ def __init__( 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 61e75c4adc293..2d9fca4a971e5 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 e7754f128754a..b8b9c8526dadd 100644 --- a/airflow/providers/facebook/ads/hooks/ads.py +++ b/airflow/providers/facebook/ads/hooks/ads.py @@ -66,9 +66,8 @@ def __init__( 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 6ec62f9665906..54892da965a97 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 1f9b04ec0970d..822efe5dfc4ed 100644 --- a/airflow/providers/google/ads/hooks/ads.py +++ b/airflow/providers/google/ads/hooks/ads.py @@ -79,9 +79,8 @@ def __init__( 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 597e5442f2f7b..6e8f7774fc5b6 100644 --- a/airflow/providers/google/cloud/hooks/cloud_sql.py +++ b/airflow/providers/google/cloud/hooks/cloud_sql.py @@ -771,9 +771,8 @@ def __init__( 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 6b6cee61ce3d3..9e006fa99ffe4 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 945297cd47a4a..cd725b9f210c8 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 b160a2e2b2cff..ccce50d896556 100644 --- a/airflow/providers/google/common/hooks/base_google.py +++ b/airflow/providers/google/common/hooks/base_google.py @@ -239,9 +239,8 @@ def __init__( 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 9b5002fb3e6d5..16d2773badd7d 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 d67c1fe166df7..a6a3ca1271fb4 100644 --- a/airflow/providers/grpc/hooks/grpc.py +++ b/airflow/providers/grpc/hooks/grpc.py @@ -71,9 +71,8 @@ def __init__( 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 162834c7fa639..4edf616652e12 100644 --- a/airflow/providers/hashicorp/hooks/vault.py +++ b/airflow/providers/hashicorp/hooks/vault.py @@ -125,7 +125,7 @@ def __init__( 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 7b98ec25dfdee..8ba5d08ab383b 100644 --- a/airflow/providers/http/hooks/http.py +++ b/airflow/providers/http/hooks/http.py @@ -68,9 +68,8 @@ def __init__( 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 @@ def __init__( 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 f00da812b95b0..1ff2c7154b7f8 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 043f1a188d789..afdde319a8479 100644 --- a/airflow/providers/jenkins/hooks/jenkins.py +++ b/airflow/providers/jenkins/hooks/jenkins.py @@ -59,8 +59,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 5cefc7c888e36..bbe46c4a1f559 100644 --- a/airflow/providers/microsoft/azure/hooks/adx.py +++ b/airflow/providers/microsoft/azure/hooks/adx.py @@ -120,8 +120,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 e9dc3776deeeb..615516555438c 100644 --- a/airflow/providers/microsoft/azure/hooks/asb.py +++ b/airflow/providers/microsoft/azure/hooks/asb.py @@ -75,8 +75,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 d77376ba0361b..9ec7aedd4b3b3 100644 --- a/airflow/providers/microsoft/azure/hooks/base_azure.py +++ b/airflow/providers/microsoft/azure/hooks/base_azure.py @@ -86,10 +86,10 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 2d26cc9f03f71..f65b97f5a149b 100644 --- a/airflow/providers/microsoft/azure/hooks/batch.py +++ b/airflow/providers/microsoft/azure/hooks/batch.py @@ -73,8 +73,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 4c8c3c40617b4..acc704dfdf616 100644 --- a/airflow/providers/microsoft/azure/hooks/container_registry.py +++ b/airflow/providers/microsoft/azure/hooks/container_registry.py @@ -84,8 +84,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 1e253404ce922..5fa926bc1bd20 100644 --- a/airflow/providers/microsoft/azure/hooks/container_volume.py +++ b/airflow/providers/microsoft/azure/hooks/container_volume.py @@ -83,10 +83,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 fef2ead2e4ce3..cf56924609fff 100644 --- a/airflow/providers/microsoft/azure/hooks/cosmos.py +++ b/airflow/providers/microsoft/azure/hooks/cosmos.py @@ -103,8 +103,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 41d8888417c93..83181e89c0b55 100644 --- a/airflow/providers/microsoft/azure/hooks/data_factory.py +++ b/airflow/providers/microsoft/azure/hooks/data_factory.py @@ -184,10 +184,10 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 f69dd8d8ead9b..0b247ac7fcd2f 100644 --- a/airflow/providers/microsoft/azure/hooks/data_lake.py +++ b/airflow/providers/microsoft/azure/hooks/data_lake.py @@ -97,8 +97,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 5b52ffbe02ae7..a051dbadadc14 100644 --- a/airflow/providers/microsoft/azure/hooks/fileshare.py +++ b/airflow/providers/microsoft/azure/hooks/fileshare.py @@ -80,9 +80,8 @@ def __init__( 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 8e7e662cdc400..397c82640dfbc 100644 --- a/airflow/providers/microsoft/azure/hooks/synapse.py +++ b/airflow/providers/microsoft/azure/hooks/synapse.py @@ -94,12 +94,12 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: } 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 ea0318b9103f1..7d05ac862b1b2 100644 --- a/airflow/providers/microsoft/azure/hooks/wasb.py +++ b/airflow/providers/microsoft/azure/hooks/wasb.py @@ -128,9 +128,8 @@ def __init__( 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 df0a766dbdad2..d77e73c278bdb 100644 --- a/airflow/providers/microsoft/psrp/hooks/psrp.py +++ b/airflow/providers/microsoft/psrp/hooks/psrp.py @@ -88,9 +88,7 @@ def __init__( 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 e25bed7e393e1..b8a2b56d465b4 100644 --- a/airflow/providers/microsoft/winrm/hooks/winrm.py +++ b/airflow/providers/microsoft/winrm/hooks/winrm.py @@ -90,9 +90,8 @@ def __init__( 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 9eacfb68170c6..f883a33ad6ac8 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 3a807b1440009..8dab4e12e58a1 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 0d837150bf14a..82ef03eb409d9 100644 --- a/airflow/providers/pagerduty/hooks/pagerduty.py +++ b/airflow/providers/pagerduty/hooks/pagerduty.py @@ -77,8 +77,8 @@ def get_connection_form_widgets(cls) -> dict[str, Any]: ), } - 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 cfa8df30bea67..0a3fa3727dfef 100644 --- a/airflow/providers/pagerduty/hooks/pagerduty_events.py +++ b/airflow/providers/pagerduty/hooks/pagerduty_events.py @@ -58,12 +58,9 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: } 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 d8f73771d5213..f15605556cf87 100644 --- a/airflow/providers/pinecone/hooks/pinecone.py +++ b/airflow/providers/pinecone/hooks/pinecone.py @@ -66,8 +66,7 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: "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 157614f00123c..a481dbe5651f6 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 3dd47f1c36ac6..af3ef1292b437 100644 --- a/airflow/providers/salesforce/hooks/salesforce.py +++ b/airflow/providers/salesforce/hooks/salesforce.py @@ -72,9 +72,8 @@ def __init__( 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 ca0d478bbbefc..e4745be6cefd8 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 392d14a683b3f..258716387d603 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 b25282f370da6..12d02da748b12 100644 --- a/airflow/providers/slack/hooks/slack.py +++ b/airflow/providers/slack/hooks/slack.py @@ -114,7 +114,7 @@ def __init__( 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 a36dcbde282e2..fcf25e44aa49f 100644 --- a/airflow/providers/slack/hooks/slack_webhook.py +++ b/airflow/providers/slack/hooks/slack_webhook.py @@ -111,7 +111,7 @@ def __init__( 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 b6638c9a67074..4712180eac971 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 79a6f23ae3f8d..db69cd53e541a 100644 --- a/airflow/providers/ssh/hooks/ssh.py +++ b/airflow/providers/ssh/hooks/ssh.py @@ -118,9 +118,8 @@ def __init__( 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 cd865aa4089a8..a02b997d81c21 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 9fd408581d7e1..3d0835282e4be 100644 --- a/airflow/providers/tabular/hooks/tabular.py +++ b/airflow/providers/tabular/hooks/tabular.py @@ -61,8 +61,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: }, } - 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 47a5e070dd56f..984f18a1bade6 100644 --- a/airflow/providers/telegram/hooks/telegram.py +++ b/airflow/providers/telegram/hooks/telegram.py @@ -63,9 +63,8 @@ def __init__( 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 67afc2d59f718..d76fbc718268a 100644 --- a/airflow/providers/yandex/hooks/yandex.py +++ b/airflow/providers/yandex/hooks/yandex.py @@ -121,9 +121,8 @@ def __init__( 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 40671a2e4f3c3..00ff3b94f0d4e 100644 --- a/airflow/providers/zendesk/hooks/zendesk.py +++ b/airflow/providers/zendesk/hooks/zendesk.py @@ -48,8 +48,8 @@ def get_ui_field_behaviour(cls) -> dict[str, Any]: "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()