airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/2] incubator-airflow git commit: [AIRFLOW-256] Fix test_scheduler_reschedule heartrate
Date Fri, 17 Jun 2016 19:20:40 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master adcccfa26 -> d243c003b


[AIRFLOW-256] Fix test_scheduler_reschedule heartrate

test_scheduler_reschedule runs two schedulerjob quite
fast after one another this sometimes is faster than
the heartrate allows and thus the tasks will not get
rescheduled and the test will fail. Fixed by setting
heartrate to 0.


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/ab2d71be
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/ab2d71be
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/ab2d71be

Branch: refs/heads/master
Commit: ab2d71be199708918c1f6d85f0c48c51c777f1e4
Parents: ce362c3
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Fri Jun 17 20:52:38 2016 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Fri Jun 17 20:52:38 2016 +0200

----------------------------------------------------------------------
 tests/jobs.py | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/ab2d71be/tests/jobs.py
----------------------------------------------------------------------
diff --git a/tests/jobs.py b/tests/jobs.py
index 3618ce4..0619f3d 100644
--- a/tests/jobs.py
+++ b/tests/jobs.py
@@ -770,6 +770,7 @@ class SchedulerJobTest(unittest.TestCase):
         @mock.patch('airflow.models.DagBag.collect_dags')
         def do_schedule(function, function2):
             scheduler = SchedulerJob(num_runs=1, executor=executor,)
+            scheduler.heartrate = 0
             scheduler.run()
 
         do_schedule()


Mime
View raw message