(airflow) branch main updated: fix(provider): Fix kwargs handling in Azure Data Lake Storage V2 Hook methods (#51847)

[weilee]

This is an automated email from the ASF dual-hosted git repository.

weilee 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 39d5103e8d1 fix(provider): Fix kwargs handling in Azure Data Lake 
Storage V2 Hook methods (#51847)
39d5103e8d1 is described below

commit 39d5103e8d1794f8da0d0f4247211dca60946df5
Author: omrdyngc <omerdayan...@outlook.com>
AuthorDate: Tue Jun 24 16:04:24 2025 +0100

    fix(provider): Fix kwargs handling in Azure Data Lake Storage V2 Hook 
methods (#51847)
---
 .../src/airflow/providers/microsoft/azure/hooks/data_lake.py      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_lake.py
 
b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_lake.py
index 3e479c530e5..f18ba472015 100644
--- 
a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_lake.py
+++ 
b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_lake.py
@@ -424,7 +424,7 @@ class AzureDataLakeStorageV2Hook(BaseHook):
         :param file_system_name: Name of the file system or instance of 
FileSystemProperties.
         :param directory_name: Name of the directory which needs to be created 
in the file system.
         """
-        result = 
self.get_file_system(file_system_name).create_directory(directory_name, kwargs)
+        result = 
self.get_file_system(file_system_name).create_directory(directory_name, 
**kwargs)
         return result
 
     def get_directory_client(
@@ -479,7 +479,7 @@ class AzureDataLakeStorageV2Hook(BaseHook):
         """
         file_client = self.create_file(file_system_name, file_name)
         with open(file_path, "rb") as data:
-            file_client.upload_data(data, overwrite=overwrite, kwargs=kwargs)
+            file_client.upload_data(data, overwrite=overwrite, **kwargs)
 
     def upload_file_to_directory(
         self,
@@ -500,9 +500,9 @@ class AzureDataLakeStorageV2Hook(BaseHook):
         :param overwrite: Boolean flag to overwrite an existing file or not.
         """
         directory_client = self.get_directory_client(file_system_name, 
directory_name=directory_name)
-        file_client = directory_client.create_file(file_name, kwargs=kwargs)
+        file_client = directory_client.create_file(file_name, **kwargs)
         with open(file_path, "rb") as data:
-            file_client.upload_data(data, overwrite=overwrite, kwargs=kwargs)
+            file_client.upload_data(data, overwrite=overwrite, **kwargs)
 
     def list_files_directory(
         self, file_system_name: FileSystemProperties | str, directory_name: str