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

shahar 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 a533af5f788 Enable PT006 rule to microsoft Provider test(operators) 
(#57928)
a533af5f788 is described below

commit a533af5f788f70100ef793c83b41fc0087961ee6
Author: GUAN-HAO HUANG <[email protected]>
AuthorDate: Sat Nov 8 02:35:50 2025 +0800

    Enable PT006 rule to microsoft Provider test(operators) (#57928)
---
 .../azure/tests/unit/microsoft/azure/operators/test_asb.py          | 6 +++---
 .../azure/tests/unit/microsoft/azure/operators/test_data_factory.py | 4 ++--
 .../azure/tests/unit/microsoft/azure/operators/test_synapse.py      | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_asb.py 
b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_asb.py
index 8cbca431cc4..aff7fe8f8b6 100644
--- a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_asb.py
+++ b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_asb.py
@@ -57,7 +57,7 @@ SUBSCRIPTION_NAME = "sb_mgmt_subscription"
 
 class TestAzureServiceBusCreateQueueOperator:
     @pytest.mark.parametrize(
-        "mock_dl_msg_expiration, mock_batched_operation",
+        ("mock_dl_msg_expiration", "mock_batched_operation"),
         [
             (True, True),
             (True, False),
@@ -131,7 +131,7 @@ class TestAzureServiceBusDeleteQueueOperator:
 
 class TestAzureServiceBusSendMessageOperator:
     @pytest.mark.parametrize(
-        "mock_message, mock_batch_flag, mock_message_id, mock_reply_to, 
mock_headers",
+        ("mock_message", "mock_batch_flag", "mock_message_id", 
"mock_reply_to", "mock_headers"),
         [
             (MESSAGE, True, None, None, None),
             (MESSAGE, False, "test_message_id", "test_reply_to", 
{"test_header": "test_value"}),
@@ -372,7 +372,7 @@ class TestASBCreateSubscriptionOperator:
         mock_log_info.assert_called_with("Created subscription %s", 
SUBSCRIPTION_NAME)
 
     @pytest.mark.parametrize(
-        "mock_subscription_name, mock_topic_name",
+        ("mock_subscription_name", "mock_topic_name"),
         [("subscription_1", None), (None, "topic_1")],
     )
     @mock.patch("airflow.providers.microsoft.azure.hooks.asb.AdminClientHook")
diff --git 
a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_data_factory.py
 
b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_data_factory.py
index 714bb3a4f38..7fd2e08d327 100644
--- 
a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_data_factory.py
+++ 
b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_data_factory.py
@@ -103,7 +103,7 @@ class TestAzureDataFactoryRunPipelineOperator:
 
     @patch.object(AzureDataFactoryHook, "run_pipeline", 
return_value=MagicMock(**PIPELINE_RUN_RESPONSE))
     @pytest.mark.parametrize(
-        "pipeline_run_status,expected_output",
+        ("pipeline_run_status", "expected_output"),
         [
             (AzureDataFactoryPipelineRunStatus.SUCCEEDED, None),
             (AzureDataFactoryPipelineRunStatus.FAILED, "exception"),
@@ -226,7 +226,7 @@ class TestAzureDataFactoryRunPipelineOperator:
 
     @pytest.mark.db_test
     @pytest.mark.parametrize(
-        "resource_group,factory",
+        ("resource_group", "factory"),
         [
             # Both resource_group_name and factory_name are passed to the 
operator.
             ("op-resource-group", "op-factory-name"),
diff --git 
a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_synapse.py
 
b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_synapse.py
index cda6b791e20..92457324c07 100644
--- 
a/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_synapse.py
+++ 
b/providers/microsoft/azure/tests/unit/microsoft/azure/operators/test_synapse.py
@@ -164,7 +164,7 @@ class TestAzureSynapseRunPipelineOperator:
 
     @patch.object(AzureSynapsePipelineHook, "run_pipeline", 
return_value=MagicMock(**PIPELINE_RUN_RESPONSE))
     @pytest.mark.parametrize(
-        "pipeline_run_status,expected_output",
+        ("pipeline_run_status", "expected_output"),
         [
             (AzureSynapsePipelineRunStatus.SUCCEEDED, None),
             (AzureSynapsePipelineRunStatus.FAILED, "exception"),

Reply via email to