gopidesupavan commented on code in PR #53541:
URL: https://github.com/apache/airflow/pull/53541#discussion_r2231791290
##########
providers/standard/tests/unit/standard/operators/test_latest_only_operator.py:
##########
@@ -312,3 +312,22 @@ def test_zero_length_interval_treated_as_latest(self,
run_task):
# The task will raise DownstreamTasksSkipped exception if it is not
the latest run
assert run_task.state == State.SUCCESS
+
+ def test_regular_latest_only_run(self, dag_maker):
+ """Test latest_only running in normal mode."""
+ with dag_maker(
+ "test_dag",
+ start_date=DEFAULT_DATE,
+ schedule="* * * * *",
+ catchup=False,
+ ):
+ latest_task = LatestOnlyOperator(task_id="latest")
+ downstream_task = EmptyOperator(task_id="downstream")
+ latest_task >> downstream_task
+
+ dr = dag_maker.create_dagrun(
+ run_type=DagRunType.SCHEDULED,
+ )
+
+ dag_maker.run_ti("latest", dr)
+ # Need help running this task and checking that the latest only
operator didn't fail
Review Comment:
```suggestion
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
