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()