fb09c57ce108bd684a1bfe8a0a969635bf9d0bb9,reframe/frontend/executors/policies.py,SerialExecutionPolicy,runcase,#SerialExecutionPolicy#Any#,48

Before Change

                getlogger().debug(
                    "polling rate (real): %.3f polls/sec" % real_rate)

                desired_rate = pollrate(t_elapsed, real_rate)
                getlogger().debug(
                    "polling rate (desired): %.3f" % desired_rate)
                t = 1 / desired_rate
                getlogger().debug("sleeping: %.3fs" % t)
                time.sleep(t)

            task.wait()

After Change

            task.compile()
            task.compile_wait()
            task.run()
            sleeptime = itertools.cycle(range(1, 11))
            num_polls = 0
            t_start = datetime.now()
            while True:
                num_polls += 1
                sched.poll(task.check.job)
                if task.poll():
                    break

                t = next(sleeptime)
                getlogger().debug("sleeping: %.3fs" % t)
                time.sleep(t)

            task.wait()

Instances