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"),