|
@@ -119,12 +119,7 @@ def dq_predict(opt):
|
|
|
def cdq_predict(opt):
|
|
|
# ---------------------------- 配置计算资源和任务 ----------------------------
|
|
|
config = opt.__dict__
|
|
|
- # 初始化资源管理器
|
|
|
- rc = ResourceController(
|
|
|
- max_workers=opt.system['max_workers'],
|
|
|
- gpu_list=opt.system['gpu_devices']
|
|
|
- )
|
|
|
- # 生成任务列表
|
|
|
+ # 超短期预测任务
|
|
|
loader = MaterialLoader(opt)
|
|
|
task = CDQTaskPre(loader, opt)
|
|
|
task.cdq_task(config)
|