airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-682] Bump MAX_PERIODS to make mark_success work for large DAGs
Date Wed, 07 Dec 2016 19:31:06 GMT
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 <dan.davydov@airbnb.com>
Authored: Wed Dec 7 11:31:02 2016 -0800
Committer: Dan Davydov <dan.davydov@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()


Mime
View raw message