This is an automated email from the ASF dual-hosted git repository.
potiuk 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 38fefc1ca95 Fix invalid cron expression in OpenLineage system test Dag
(#74187)
38fefc1ca95 is described below
commit 38fefc1ca95f7cdf76d16291f256675f2ccb419c
Author: Shahar Epstein <[email protected]>
AuthorDate: Mon Oct 5 03:21:36 2026 +0300
Fix invalid cron expression in OpenLineage system test Dag (#74187)
The second expression of the MultipleCronTriggerTimetable in the
openlineage_schedule_multiple_cron_trigger_timetable_dag system test
used hour 27, which croniter rejects with CroniterBadCronError. The
Dag processor then logged "Failed to fetch run info ... for DAG
'openlineage_schedule_multiple_cron_trigger_timetable_dag'" on every
re-parse, flooding the OpenLineage e2e compatibility job logs.
Hour 17 keeps the Dag's intent: two cron expressions that never
trigger a run on their own during the test. The expected OpenLineage
events are updated to match the corrected timetable.
---
...enlineage_schedule_multiple_cron_trigger_timetable_dag.py | 2 +-
...lineage_schedule_multiple_cron_trigger_timetable_dag.json | 12 ++++++------
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/providers/openlineage/tests/system/openlineage/example_openlineage_schedule_multiple_cron_trigger_timetable_dag.py
b/providers/openlineage/tests/system/openlineage/example_openlineage_schedule_multiple_cron_trigger_timetable_dag.py
index f296fad0a6f..46264980e19 100644
---
a/providers/openlineage/tests/system/openlineage/example_openlineage_schedule_multiple_cron_trigger_timetable_dag.py
+++
b/providers/openlineage/tests/system/openlineage/example_openlineage_schedule_multiple_cron_trigger_timetable_dag.py
@@ -41,7 +41,7 @@ with DAG(
dagrun_timeout=DEFAULT_DAGRUN_TIMEOUT,
dag_id=DAG_ID,
start_date=datetime(2021, 1, 1),
- schedule=MultipleCronTriggerTimetable("21 13 29 2 4", "9 27 29 2 4",
timezone="UTC"),
+ schedule=MultipleCronTriggerTimetable("21 13 29 2 4", "9 17 29 2 4",
timezone="UTC"),
catchup=False,
default_args={"retries": 0},
) as dag:
diff --git
a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_multiple_cron_trigger_timetable_dag.json
b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_multiple_cron_trigger_timetable_dag.json
index c989e61330f..e87beb81392 100644
---
a/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_multiple_cron_trigger_timetable_dag.json
+++
b/providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_multiple_cron_trigger_timetable_dag.json
@@ -8,13 +8,13 @@
"timetable": {
"expressions": [
"21 13 29 2 4",
- "9 27 29 2 4"
+ "9 17 29 2 4"
],
"timezone": "UTC",
"interval": 0.0,
"run_immediately": false
},
- "timetable_summary": "21 13 29 2 4, 9 27 29 2 4"
+ "timetable_summary": "21 13 29 2 4, 9 17 29 2 4"
}
}
}
@@ -32,13 +32,13 @@
"timetable": {
"expressions": [
"21 13 29 2 4",
- "9 27 29 2 4"
+ "9 17 29 2 4"
],
"timezone": "UTC",
"interval": 0.0,
"run_immediately": false
},
- "timetable_summary": "21 13 29 2 4, 9 27 29 2 4"
+ "timetable_summary": "21 13 29 2 4, 9 17 29 2 4"
}
}
}
@@ -56,13 +56,13 @@
"timetable": {
"expressions": [
"21 13 29 2 4",
- "9 27 29 2 4"
+ "9 17 29 2 4"
],
"timezone": "UTC",
"interval": 0.0,
"run_immediately": false
},
- "timetable_summary": "21 13 29 2 4, 9 27 29 2 4"
+ "timetable_summary": "21 13 29 2 4, 9 17 29 2 4"
}
}
}
