This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 d7722e42027 Enable PT006 rule to microsoft Provider test(transfers)
(#57925)
d7722e42027 is described below
commit d7722e42027b4ab5ed622bfbec12338cfc54d1ca
Author: GUAN-HAO HUANG <[email protected]>
AuthorDate: Fri Nov 7 21:04:27 2025 +0800
Enable PT006 rule to microsoft Provider test(transfers) (#57925)
---
.../azure/tests/unit/microsoft/azure/transfers/test_s3_to_wasb.py | 6 +++---
.../azure/tests/unit/microsoft/azure/triggers/test_data_factory.py | 4 ++--
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/providers/microsoft/azure/tests/unit/microsoft/azure/transfers/test_s3_to_wasb.py
b/providers/microsoft/azure/tests/unit/microsoft/azure/transfers/test_s3_to_wasb.py
index 6d96a8f8306..4858e29a183 100644
---
a/providers/microsoft/azure/tests/unit/microsoft/azure/transfers/test_s3_to_wasb.py
+++
b/providers/microsoft/azure/tests/unit/microsoft/azure/transfers/test_s3_to_wasb.py
@@ -124,7 +124,7 @@ class TestS3ToAzureBlobStorageOperator:
@mock.patch("airflow.providers.microsoft.azure.transfers.s3_to_wasb.S3Hook")
@mock.patch("airflow.providers.microsoft.azure.transfers.s3_to_wasb.WasbHook")
@pytest.mark.parametrize( # Please see line 37 above for args used for
parametrization
-
"s3_existing_files,wasb_existing_files,returned_files,s3_prefix,blob_prefix,replace",
+ ("s3_existing_files", "wasb_existing_files", "returned_files",
"s3_prefix", "blob_prefix", "replace"),
[
# s3_existing files, wasb_existing_files, returned_files,
s3_prefix, wasb_prefix, replace
(MOCK_FILES, [], MOCK_FILES, PREFIX, PREFIX, False), # Task 1
from above
@@ -161,7 +161,7 @@ class TestS3ToAzureBlobStorageOperator:
@mock.patch("airflow.providers.microsoft.azure.transfers.s3_to_wasb.WasbHook")
@pytest.mark.parametrize(
- "azure_file_exists,returned_files,replace",
+ ("azure_file_exists", "returned_files", "replace"),
[
# azure_file_exists, returned_files, replace
(False, ["TEST1.csv"], False), # Task 4 from above
@@ -189,7 +189,7 @@ class TestS3ToAzureBlobStorageOperator:
@mock.patch("airflow.providers.microsoft.azure.transfers.s3_to_wasb.WasbHook")
@pytest.mark.parametrize(
- "wasb_existing_files,returned_files",
+ ("wasb_existing_files", "returned_files"),
[
# wasb_existing_files, returned_files
([], ["TEST1.csv"]), # Task 8 from above
diff --git
a/providers/microsoft/azure/tests/unit/microsoft/azure/triggers/test_data_factory.py
b/providers/microsoft/azure/tests/unit/microsoft/azure/triggers/test_data_factory.py
index fd1a2065540..06d7a6cb32a 100644
---
a/providers/microsoft/azure/tests/unit/microsoft/azure/triggers/test_data_factory.py
+++
b/providers/microsoft/azure/tests/unit/microsoft/azure/triggers/test_data_factory.py
@@ -128,7 +128,7 @@ class TestADFPipelineRunStatusSensorTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "mock_status, mock_message",
+ ("mock_status", "mock_message"),
[
("Failed", f"Pipeline run {RUN_ID} has Failed."),
],
@@ -146,7 +146,7 @@ class TestADFPipelineRunStatusSensorTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "mock_status, mock_message",
+ ("mock_status", "mock_message"),
[
("Cancelled", f"Pipeline run {RUN_ID} has been Cancelled."),
],