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 138eddfa8bc modify all remaining files related to airflow-core (#58015)
138eddfa8bc is described below
commit 138eddfa8bc091bf59e6385d80b5022b1c2d7685
Author: Chao-Hung Wan <[email protected]>
AuthorDate: Fri Nov 7 21:08:55 2025 +0800
modify all remaining files related to airflow-core (#58015)
---
.../api_fastapi/core_api/services/public/test_task_instances.py | 8 +++++++-
airflow-core/tests/unit/api_fastapi/core_api/test_security.py | 6 +++---
airflow-core/tests/unit/api_fastapi/test_app.py | 2 +-
airflow-core/tests/unit/assets/test_evaluation.py | 8 ++++----
airflow-core/tests/unit/callbacks/test_callback_requests.py | 4 ++--
airflow-core/tests/unit/charts/log_groomer.py | 4 ++--
6 files changed, 19 insertions(+), 13 deletions(-)
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/services/public/test_task_instances.py
b/airflow-core/tests/unit/api_fastapi/core_api/services/public/test_task_instances.py
index 5c8b5991ac5..fb169929d32 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/services/public/test_task_instances.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/services/public/test_task_instances.py
@@ -57,7 +57,13 @@ class TestCategorizeTaskInstances(TestTaskInstanceEndpoint):
return "test_user"
@pytest.mark.parametrize(
- "task_keys, expected_matched_keys, expected_not_found_keys,
expected_matched_count, expected_not_found_count",
+ (
+ "task_keys",
+ "expected_matched_keys",
+ "expected_not_found_keys",
+ "expected_matched_count",
+ "expected_not_found_count",
+ ),
[
pytest.param(
{(TASK_ID_1, -1), (TASK_ID_2, -1)},
diff --git a/airflow-core/tests/unit/api_fastapi/core_api/test_security.py
b/airflow-core/tests/unit/api_fastapi/core_api/test_security.py
index 6aea3b23528..b0000147438 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/test_security.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/test_security.py
@@ -118,7 +118,7 @@ class TestFastApiSecurity:
mock_resolve_user_from_token.assert_not_called()
@pytest.mark.parametrize(
- "oauth_token, bearer_credentials_creds, cookies, expected",
+ ("oauth_token", "bearer_credentials_creds", "cookies", "expected"),
[
("oauth_token", None, {}, "oauth_token"),
(None, "bearer_credentials_creds", {}, "bearer_credentials_creds"),
@@ -177,7 +177,7 @@ class TestFastApiSecurity:
auth_manager.is_authorized_dag.assert_called_once()
@pytest.mark.parametrize(
- "url, expected_is_safe",
+ ("url", "expected_is_safe"),
[
("https://server_base_url.com/prefix/some_page?with_param=3";,
True),
("https://server_base_url.com/prefix/";, True),
@@ -211,7 +211,7 @@ class TestFastApiSecurity:
assert is_safe_url(url, request=request) == expected_is_safe
@pytest.mark.parametrize(
- "url, expected_is_safe",
+ ("url", "expected_is_safe"),
[
("https://server_base_url.com/prefix";, False),
("https://requesting_server_base_url.com/prefix2";, True),
diff --git a/airflow-core/tests/unit/api_fastapi/test_app.py
b/airflow-core/tests/unit/api_fastapi/test_app.py
index 448d527ab6b..1e0925f8e73 100644
--- a/airflow-core/tests/unit/api_fastapi/test_app.py
+++ b/airflow-core/tests/unit/api_fastapi/test_app.py
@@ -97,7 +97,7 @@ def test_catch_all_route_last(client):
@pytest.mark.parametrize(
- "fastapi_apps, expected_message, invalid_path",
+ ("fastapi_apps", "expected_message", "invalid_path"),
[
(
[{"name": "test", "app": FastAPI(), "url_prefix": ""}],
diff --git a/airflow-core/tests/unit/assets/test_evaluation.py
b/airflow-core/tests/unit/assets/test_evaluation.py
index 4abf42c3e0e..3f4b1f3b696 100644
--- a/airflow-core/tests/unit/assets/test_evaluation.py
+++ b/airflow-core/tests/unit/assets/test_evaluation.py
@@ -35,7 +35,7 @@ def evaluator(session):
@pytest.mark.parametrize(
- "statuses, result",
+ ("statuses", "result"),
[
({AssetUniqueKey.from_asset(asset1): True}, True),
({AssetUniqueKey.from_asset(asset1): False}, False),
@@ -47,7 +47,7 @@ def test_asset_evaluate(evaluator, statuses, result):
@pytest.mark.parametrize(
- "condition, statuses, result",
+ ("condition", "statuses", "result"),
[
(
AssetAny(asset1, asset2),
@@ -76,7 +76,7 @@ def test_assset_boolean_condition_evaluate_iter(evaluator,
condition, statuses,
@pytest.mark.parametrize(
- "inputs, scenario, expected",
+ ("inputs", "scenario", "expected"),
[
# Scenarios for AssetAny
((True, True, True), "any", True),
@@ -115,7 +115,7 @@ def
test_asset_logical_conditions_evaluation_and_serialization(evaluator, inputs
@pytest.mark.parametrize(
- "status_values, expected_evaluation",
+ ("status_values", "expected_evaluation"),
[
pytest.param(
(False, True, True),
diff --git a/airflow-core/tests/unit/callbacks/test_callback_requests.py
b/airflow-core/tests/unit/callbacks/test_callback_requests.py
index 8f1d959e27e..d6bf66b8d77 100644
--- a/airflow-core/tests/unit/callbacks/test_callback_requests.py
+++ b/airflow-core/tests/unit/callbacks/test_callback_requests.py
@@ -45,7 +45,7 @@ pytestmark = pytest.mark.db_test
class TestCallbackRequest:
@pytest.mark.parametrize(
- "input,request_class",
+ ("input", "request_class"),
[
(
None, # to be generated when test is run
@@ -98,7 +98,7 @@ class TestCallbackRequest:
assert input == result
@pytest.mark.parametrize(
- "task_callback_type,expected_is_failure",
+ ("task_callback_type", "expected_is_failure"),
[
(None, True),
(TaskInstanceState.FAILED, True),
diff --git a/airflow-core/tests/unit/charts/log_groomer.py
b/airflow-core/tests/unit/charts/log_groomer.py
index 0f64a137631..fa66aed10e9 100644
--- a/airflow-core/tests/unit/charts/log_groomer.py
+++ b/airflow-core/tests/unit/charts/log_groomer.py
@@ -165,7 +165,7 @@ class LogGroomerTestBase:
assert jmespath.search("spec.template.spec.containers[1].command",
docs[0]) == ["release-name"]
assert jmespath.search("spec.template.spec.containers[1].args",
docs[0]) == ["Helm"]
- @pytest.mark.parametrize("retention_days, retention_result", [(None,
None), (30, "30")])
+ @pytest.mark.parametrize(("retention_days", "retention_result"), [(None,
None), (30, "30")])
def test_log_groomer_retention_days_overrides(self, retention_days,
retention_result):
if self.obj_name == "dag-processor":
values = {
@@ -190,7 +190,7 @@ class LogGroomerTestBase:
else:
assert len(jmespath.search("spec.template.spec.containers[1].env",
docs[0])) == 2
- @pytest.mark.parametrize("frequency_minutes, frequency_result", [(None,
None), (20, "20")])
+ @pytest.mark.parametrize(("frequency_minutes", "frequency_result"),
[(None, None), (20, "20")])
def test_log_groomer_frequency_minutes_overrides(self, frequency_minutes,
frequency_result):
if self.obj_name == "dag-processor":
values = {
