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)

After Change

        // 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:],
                                                 self.end_stamps[:-max_jobs])]
        self.assertTrue(all(begin_after_end))

        // NOTE: to assure that these remaining jobs were also run
        // in parallel one could do the command hereafter; however, it would

Instances