190191192193194195196197198199200
task = new LoadTask(pipeline.getId()); } if (task != null) { OtterContextLocator.autowire(task); // 注入一下spring资源 task.start(); tasks.put(taskType, task); logger.info("INFO ## start this task = {} success", taskType.toString()); } }