You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by da...@apache.org on 2016/12/07 19:31:06 UTC
incubator-airflow git commit: [AIRFLOW-682] Bump MAX_PERIODS to make
mark_success work for large DAGs
Repository: incubator-airflow
Updated Branches:
refs/heads/master 64a1b19a3 -> 37a324ae4
[AIRFLOW-682] Bump MAX_PERIODS to make mark_success work for large DAGs
It is not possible to mark success on some large
DAGs due to the MAX_PERIODS being set to 1000. We
should temporarily bump it up until work can be
done to scale the mark success endpoint much
higher.
Testing Done:
- Has been running in Airbnb prod for many months
now
Closes #1928 from aoen/ddavydov/bump_max_periods
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/37a324ae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/37a324ae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/37a324ae
Branch: refs/heads/master
Commit: 37a324ae4ffeee6b4a460cebe3c1cfec8f6ef91a
Parents: 64a1b19
Author: Dan Davydov <da...@airbnb.com>
Authored: Wed Dec 7 11:31:02 2016 -0800
Committer: Dan Davydov <da...@airbnb.com>
Committed: Wed Dec 7 11:31:02 2016 -0800
----------------------------------------------------------------------
airflow/www/views.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/37a324ae/airflow/www/views.py
----------------------------------------------------------------------
diff --git a/airflow/www/views.py b/airflow/www/views.py
index d22e8e4..7134264 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -1095,7 +1095,7 @@ class Airflow(BaseView):
future = request.args.get('future') == "true"
past = request.args.get('past') == "true"
recursive = request.args.get('recursive') == "true"
- MAX_PERIODS = 1000
+ MAX_PERIODS = 5000
# Flagging tasks as successful
session = settings.Session()