You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by mo...@apache.org on 2025/07/07 11:19:47 UTC
(airflow) branch main updated: fix: Adjust OL system test to latest changes (#52971)
This is an automated email from the ASF dual-hosted git repository.
mobuchowski 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 9f70af5816f fix: Adjust OL system test to latest changes (#52971)
9f70af5816f is described below
commit 9f70af5816f52298b018b935259418b8882002d2
Author: Kacper Muda <mu...@gmail.com>
AuthorDate: Mon Jul 7 13:19:40 2025 +0200
fix: Adjust OL system test to latest changes (#52971)
---
.../system/openlineage/example_openlineage_base_complex_dag.py | 7 +------
.../expected_events/openlineage_base_complex_dag__af3.json | 2 --
.../expected_events/openlineage_schedule_timetable_dag__af3.json | 2 +-
3 files changed, 2 insertions(+), 9 deletions(-)
diff --git a/providers/openlineage/tests/system/openlineage/example_openlineage_base_complex_dag.py b/providers/openlineage/tests/system/openlineage/example_openlineage_base_complex_dag.py
index fa369bffd91..4af4854f04f 100644
--- a/providers/openlineage/tests/system/openlineage/example_openlineage_base_complex_dag.py
+++ b/providers/openlineage/tests/system/openlineage/example_openlineage_base_complex_dag.py
@@ -132,12 +132,7 @@ with DAG(
with TaskGroup("section_1", prefix_group_id=True) as tg:
task_5 = CustomMappedOperator.partial(task_id="task_5", doc_md="md doc").expand(value=[1])
with TaskGroup("section_2", parent_group=tg, tooltip="group_tooltip") as tg2:
- if AIRFLOW_VERSION.major == 3:
- add_args: dict[str, Any] = {
- "run_as_user": "some_user"
- } # Random user break task execution on AF2
- else:
- add_args = {"sla": timedelta(seconds=123)} # type: ignore[dict-item] # SLA is not present in AF3 yet
+ add_args: dict[str, Any] = {"sla": timedelta(seconds=123)} if AIRFLOW_VERSION.major == 2 else {}
task_6 = EmptyOperator(
task_id="task_6",
on_success_callback=lambda x: print(1),
diff --git a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_base_complex_dag__af3.json b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_base_complex_dag__af3.json
index eac5ba54a60..1e273e73da6 100644
--- a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_base_complex_dag__af3.json
+++ b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_base_complex_dag__af3.json
@@ -1931,7 +1931,6 @@
"outlets": "[]",
"owner": "airflow",
"priority_weight": 1,
- "run_as_user": "some_user",
"queue": "{{ result is string }}",
"retries": "{{ result is number }}",
"retry_exponential_backoff": false,
@@ -2105,7 +2104,6 @@
"outlets": "[]",
"owner": "airflow",
"priority_weight": 1,
- "run_as_user": "some_user",
"queue": "{{ result is string }}",
"retries": "{{ result is number }}",
"retry_exponential_backoff": false,
diff --git a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_timetable_dag__af3.json b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_timetable_dag__af3.json
index 537e6a22d9e..4baaeee9aa0 100644
--- a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_timetable_dag__af3.json
+++ b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_timetable_dag__af3.json
@@ -13,7 +13,7 @@
],
"restrict_to_events": false
},
- "timetable_summary": "3 events"
+ "timetable_summary": "My Team's Baseball Games"
}
}
}