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 <[email protected]> Authored: Fri Jun 17 20:52:38 2016 +0200 Committer: Bolke de Bruin <[email protected]> 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()
