This is an automated email from the ASF dual-hosted git repository.
eladkal 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 feb8307472 Resolve deprecations in `LatestOnlyOperator` tests (#40181)
feb8307472 is described below
commit feb8307472b21cd33fcf0a6860f2f42205606af7
Author: Bora Berke Sahin <67373739+borabe...@users.noreply.github.com>
AuthorDate: Thu Jun 13 14:45:58 2024 +0300
Resolve deprecations in `LatestOnlyOperator` tests (#40181)
* Resolve deprecations in `LatestOnlyOperator`
* Use explicit data_interval
---
tests/deprecations_ignore.yml | 4 ----
tests/operators/test_latest_only_operator.py | 3 +++
2 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/tests/deprecations_ignore.yml b/tests/deprecations_ignore.yml
index ada879f9c9..b657e820f9 100644
--- a/tests/deprecations_ignore.yml
+++ b/tests/deprecations_ignore.yml
@@ -45,10 +45,6 @@
-
tests/ti_deps/deps/test_prev_dagrun_dep.py::TestPrevDagrunDep::test_first_task_run_of_new_task
-# Operators
--
tests/operators/test_latest_only_operator.py::TestLatestOnlyOperator::test_skipping_non_latest
-
-
# Serialization
-
tests/serialization/test_dag_serialization.py::TestStringifiedDAGs::test_custom_dep_detector
diff --git a/tests/operators/test_latest_only_operator.py
b/tests/operators/test_latest_only_operator.py
index 7bce02de95..e67463aea0 100644
--- a/tests/operators/test_latest_only_operator.py
+++ b/tests/operators/test_latest_only_operator.py
@@ -96,6 +96,7 @@ class TestLatestOnlyOperator:
start_date=timezone.utcnow(),
execution_date=DEFAULT_DATE,
state=State.RUNNING,
+ data_interval=(DEFAULT_DATE, DEFAULT_DATE),
)
self.dag.create_dagrun(
@@ -103,6 +104,7 @@ class TestLatestOnlyOperator:
start_date=timezone.utcnow(),
execution_date=timezone.datetime(2016, 1, 1, 12),
state=State.RUNNING,
+ data_interval=(timezone.datetime(2016, 1, 1, 12),
timezone.datetime(2016, 1, 1, 12) + INTERVAL),
)
self.dag.create_dagrun(
@@ -110,6 +112,7 @@ class TestLatestOnlyOperator:
start_date=timezone.utcnow(),
execution_date=END_DATE,
state=State.RUNNING,
+ data_interval=(END_DATE, END_DATE + INTERVAL),
)
latest_task.run(start_date=DEFAULT_DATE, end_date=END_DATE)
