67c6a8aba33a47b594617c570cc0d94bb103db8a,unittests/test_policies.py,TestAsynchronousExecutionPolicy,test_concurrency_limited,#TestAsynchronousExecutionPolicy#,154

Before Change

                   SleepCheck(1, system=self.system, resources=self.resources) ]
        self.set_max_jobs(2)

        t_run = datetime.now()
        self.runner.runall(checks, self.system)
        t_run = datetime.now() - t_run
        self.assertGreaterEqual(t_run.seconds, 2)
        self.assertLess(t_run.seconds, 3)

        self.assertEqual(3, self.runner.stats.num_cases())

After Change

        self.read_timestamps_sorted()

        // Assure that the first //max_jobs jobs were run in parallel
        self.assertTrue(self.begin_stamps[max_jobs-1] < self.end_stamps[0])

        // Assure that the remaining jobs were each run after one of the
        // previous //max_jobs jobs had finished (e.g. begin[max_jobs] > end[0])
        begin_after_end = [b > e for b, e in zip(self.begin_stamps[max_jobs:],

Instances