传参形式修改
This commit is contained in:
parent
a945af0d35
commit
01fc6f5637
@ -61,7 +61,6 @@ public class ParallelDispatcher implements BaseDispatcher{
|
|||||||
latch.await();
|
latch.await();
|
||||||
// TODO 检查是否全部执行成功 ,目前没有逻辑就是忽略错误
|
// TODO 检查是否全部执行成功 ,目前没有逻辑就是忽略错误
|
||||||
}
|
}
|
||||||
// TODO 入库
|
|
||||||
}
|
}
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
|
@ -100,8 +100,8 @@ public class PipelineController {
|
|||||||
|
|
||||||
return CommonResult.success();
|
return CommonResult.success();
|
||||||
}
|
}
|
||||||
@PostMapping("/executePipeline")
|
@PostMapping("/executePipeline/{pipelineId}")
|
||||||
public CommonResult<PipelineRunContext> executePipeline(String pipelineId){
|
public CommonResult<PipelineRunContext> executePipeline(@PathVariable String pipelineId){
|
||||||
PipelineRunContext execute = pipelineExecutor.execute(pipelineId);
|
PipelineRunContext execute = pipelineExecutor.execute(pipelineId);
|
||||||
return CommonResult.success(execute);
|
return CommonResult.success(execute);
|
||||||
}
|
}
|
||||||
|
File diff suppressed because one or more lines are too long
Loading…
x
Reference in New Issue
Block a user