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 ec669b977c6 Enable PT006 rule to google Provider test (triggers)
(#57950)
ec669b977c6 is described below
commit ec669b977c6dbccca9048976c676bbc6e3d46238
Author: GUAN-HAO HUANG <[email protected]>
AuthorDate: Sat Nov 8 02:46:06 2025 +0800
Enable PT006 rule to google Provider test (triggers) (#57950)
Signed-off-by: rich7420 <[email protected]>
Co-authored-by: Kalyan R <[email protected]>
---
.../tests/unit/google/cloud/triggers/test_bigquery_dts.py | 2 +-
.../cloud/triggers/test_cloud_storage_transfer_service.py | 8 ++++----
.../tests/unit/google/cloud/triggers/test_dataflow.py | 14 +++++++-------
.../google/tests/unit/google/cloud/triggers/test_gcs.py | 12 ++++++------
.../unit/google/cloud/triggers/test_kubernetes_engine.py | 2 +-
.../tests/unit/google/cloud/triggers/test_vertex_ai.py | 2 +-
6 files changed, 20 insertions(+), 20 deletions(-)
diff --git
a/providers/google/tests/unit/google/cloud/triggers/test_bigquery_dts.py
b/providers/google/tests/unit/google/cloud/triggers/test_bigquery_dts.py
index cba7cb58993..9f65f9e38b9 100644
--- a/providers/google/tests/unit/google/cloud/triggers/test_bigquery_dts.py
+++ b/providers/google/tests/unit/google/cloud/triggers/test_bigquery_dts.py
@@ -68,7 +68,7 @@ class TestBigQueryDataTransferRunTrigger:
}
@pytest.mark.parametrize(
- "attr, expected_value",
+ ("attr", "expected_value"),
[
("gcp_conn_id", GCP_CONN_ID),
("location", LOCATION),
diff --git
a/providers/google/tests/unit/google/cloud/triggers/test_cloud_storage_transfer_service.py
b/providers/google/tests/unit/google/cloud/triggers/test_cloud_storage_transfer_service.py
index 51c8f6c92d5..b9f186b870e 100644
---
a/providers/google/tests/unit/google/cloud/triggers/test_cloud_storage_transfer_service.py
+++
b/providers/google/tests/unit/google/cloud/triggers/test_cloud_storage_transfer_service.py
@@ -157,7 +157,7 @@ class TestCloudStorageTransferServiceCreateJobsTrigger:
mock_sleep.assert_called_once_with(POLL_INTERVAL)
@pytest.mark.parametrize(
- "latest_operations_names, expected_failed_job",
+ ("latest_operations_names", "expected_failed_job"),
[
([None, LATEST_OPERATION_NAME_1], JOB_0),
([LATEST_OPERATION_NAME_0, None], JOB_1),
@@ -189,7 +189,7 @@ class TestCloudStorageTransferServiceCreateJobsTrigger:
assert actual_event == expected_event
@pytest.mark.parametrize(
- "job_statuses, failed_operation, expected_status",
+ ("job_statuses", "failed_operation", "expected_status"),
[
(
[TransferOperation.Status.ABORTED,
TransferOperation.Status.SUCCESS],
@@ -336,7 +336,7 @@ class TestCloudStorageTransferServiceCheckJobStatusTrigger:
}
@pytest.mark.parametrize(
- "attr, expected_value",
+ ("attr", "expected_value"),
[
("gcp_conn_id", GCP_CONN_ID),
("impersonation_chain", IMPERSONATION_CHAIN),
@@ -421,7 +421,7 @@ class TestCloudDataTransferServiceRunJobTrigger:
}
@pytest.mark.parametrize(
- "attr, expected_value",
+ ("attr", "expected_value"),
[
("gcp_conn_id", GCP_CONN_ID),
("impersonation_chain", IMPERSONATION_CHAIN),
diff --git a/providers/google/tests/unit/google/cloud/triggers/test_dataflow.py
b/providers/google/tests/unit/google/cloud/triggers/test_dataflow.py
index bf8cfd05d60..64c27dbb484 100644
--- a/providers/google/tests/unit/google/cloud/triggers/test_dataflow.py
+++ b/providers/google/tests/unit/google/cloud/triggers/test_dataflow.py
@@ -160,7 +160,7 @@ class TestTemplateJobStartTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -253,7 +253,7 @@ class TestDataflowJobAutoScalingEventTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -393,7 +393,7 @@ class TestDataflowJobMessagesTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -529,7 +529,7 @@ class TestDataflowJobMetricsTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -659,7 +659,7 @@ class TestDataflowJobStatusTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -780,7 +780,7 @@ class TestDataflowStartYamlJobTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
@@ -897,7 +897,7 @@ class TestDataflowJobStateCompleteTrigger:
assert actual_data == expected_data
@pytest.mark.parametrize(
- "attr, expected",
+ ("attr", "expected"),
[
("gcp_conn_id", GCP_CONN_ID),
("poll_sleep", POLL_SLEEP),
diff --git a/providers/google/tests/unit/google/cloud/triggers/test_gcs.py
b/providers/google/tests/unit/google/cloud/triggers/test_gcs.py
index 97a5597d978..27c0d3b16c3 100644
--- a/providers/google/tests/unit/google/cloud/triggers/test_gcs.py
+++ b/providers/google/tests/unit/google/cloud/triggers/test_gcs.py
@@ -133,7 +133,7 @@ class TestGCSBlobTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "exists,response",
+ ("exists", "response"),
[
(True, "success"),
(False, "pending"),
@@ -157,7 +157,7 @@ class TestGCSBlobTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "blob_list,response",
+ ("blob_list", "response"),
[
([TEST_OBJECT], "success"),
([], "pending"),
@@ -339,7 +339,7 @@ class TestGCSCheckBlobUpdateTimeTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "blob_object_update_datetime, ts_object, expected_response",
+ ("blob_object_update_datetime", "ts_object", "expected_response"),
[
(
"2022-03-07T10:05:43.535Z",
@@ -377,7 +377,7 @@ class TestGCSCheckBlobUpdateTimeTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "blob_object, expected_response",
+ ("blob_object", "expected_response"),
[
(
None,
@@ -512,7 +512,7 @@ class TestGCSUploadSessionTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "allow_delete, current_objects, response",
+ ("allow_delete", "current_objects", "response"),
[
(True, {"a", "aa", "ab"}, {"status": "pending"}),
],
@@ -539,7 +539,7 @@ class TestGCSUploadSessionTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "last_activity_time , min_objects, response",
+ ("last_activity_time", "min_objects", "response"),
[
(
datetime.now() - timedelta(hours=0, minutes=50),
diff --git
a/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
b/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
index 05e194a3f97..506d2f8191c 100644
---
a/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
+++
b/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
@@ -268,7 +268,7 @@ class TestGKEStartPodTrigger:
assert "Waiting until 120s to get the POD scheduled..." in caplog.text
@pytest.mark.parametrize(
- "container_state, expected_state",
+ ("container_state", "expected_state"),
[
(
{"running": k8s.V1ContainerStateRunning(), "terminated": None,
"waiting": None},
diff --git
a/providers/google/tests/unit/google/cloud/triggers/test_vertex_ai.py
b/providers/google/tests/unit/google/cloud/triggers/test_vertex_ai.py
index 30ea88ce2eb..a1f1fb0eb26 100644
--- a/providers/google/tests/unit/google/cloud/triggers/test_vertex_ai.py
+++ b/providers/google/tests/unit/google/cloud/triggers/test_vertex_ai.py
@@ -179,7 +179,7 @@ class TestBaseVertexAIJobTrigger:
@pytest.mark.asyncio
@pytest.mark.parametrize(
- "job_state, job_name, status, message",
+ ("job_state", "job_name", "status", "message"),
[
(
JobState.JOB_STATE_CANCELLED,
