scheduler_manager.py 文件源码

def __init__(self):
        super(SchedulerManager, self).__init__("SchedulerManager")

        self.config_opts = [
            cfg.IntOpt("backfill_depth", default=100),
        ]
        self.workers = []