You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/08/03 19:13:56 UTC
[GitHub] [airflow] jedcunningham opened a new pull request, #25454: Add ui endpoint to get "next run datasets" info
jedcunningham opened a new pull request, #25454:
URL: https://github.com/apache/airflow/pull/25454
For example, when you have 1 of 2 datasets updated since the last run, it'll return:
```
[
{"id":1, "uri":"s3://abc/dataset_never.txt", "created_at":null},
{"id":2, "uri":"s3://abc/dataset3.txt", "created_at":"2022-07-29T22:54:03.982135+00:00"}
]
```
--
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: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [airflow] jedcunningham closed pull request #25454: Add ui endpoint to get "next run datasets" info
Posted by GitBox <gi...@apache.org>.
jedcunningham closed pull request #25454: Add ui endpoint to get "next run datasets" info
URL: https://github.com/apache/airflow/pull/25454
--
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: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [airflow] bbovenzi commented on a diff in pull request #25454: Add ui endpoint to get "next run datasets" info
Posted by GitBox <gi...@apache.org>.
bbovenzi commented on code in PR #25454:
URL: https://github.com/apache/airflow/pull/25454#discussion_r936850296
##########
airflow/www/views.py:
##########
@@ -3647,6 +3647,36 @@ def grid_data(self):
{'Content-Type': 'application/json; charset=utf-8'},
)
+ @expose('/object/next_run_datasets/<string:dag_id>')
+ @auth.has_access([(permissions.ACTION_CAN_READ, permissions.RESOURCE_DAG)])
+ def next_run_datasets(self, dag_id):
+ """Returns datasets necessary, and their status, for the next dag run"""
+ with create_session() as session:
+ data = [
Review Comment:
Should we add any error handling if the dagid is invalid?
--
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: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [airflow] jedcunningham merged pull request #25454: Add ui endpoint to get "next run datasets" info
Posted by GitBox <gi...@apache.org>.
jedcunningham merged PR #25454:
URL: https://github.com/apache/airflow/pull/25454
--
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: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org