82c402cb7fab567e5becea9b8c92dd01dea953c2,studio/lworker.py,,main,#Any#,83

Before Change

                        " due lack of resources. Will retry")
            time.sleep(5)

        queue = glob.glob(fs_tracker.get_queue_directory() + "/*")

    logger.info("Queue in {} is empty, quitting"
                .format(fs_tracker.get_queue_directory()))

After Change

    config = model.get_config(parsed_args.config)

    while queue.has_next():
        first_exp, ack_key = queue.dequeue(acknowledge=False)
        // first_exp = min([(p, os.path.getmtime(p)) for p in queue],
        //                key=lambda t: t[1])[0]

Instances