You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2023/02/20 08:42:52 UTC
[airflow] branch main updated: datasets, next_run_datasets, remove unnecessary timestamp filter (#29441)
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 6f9efbd053 datasets, next_run_datasets, remove unnecessary timestamp filter (#29441)
6f9efbd053 is described below
commit 6f9efbd0537944102cd4a1cfef06e11fe0a3d03d
Author: Michael Petro <40...@users.noreply.github.com>
AuthorDate: Mon Feb 20 03:42:42 2023 -0500
datasets, next_run_datasets, remove unnecessary timestamp filter (#29441)
* datasets, next_run_datasets, remove unnecessary timestamp filter
* remove redundant `_and`
---
airflow/www/views.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/airflow/www/views.py b/airflow/www/views.py
index c4fa14ebc5..5335d7bd37 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -3706,10 +3706,7 @@ class Airflow(AirflowBaseView):
)
.join(
DatasetEvent,
- and_(
- DatasetEvent.dataset_id == DatasetModel.id,
- DatasetEvent.timestamp > DatasetDagRunQueue.created_at,
- ),
+ DatasetEvent.dataset_id == DatasetModel.id,
isouter=True,
)
.filter(DagScheduleDatasetReference.dag_id == dag_id, ~DatasetModel.is_orphaned)