1.流水线从错误处开始执行&从头开始执行,运行中流程重复发起运行报错(初步测试通过)
2.流水线执行历史查询与入库方法(初步测试通过) 3.context获取用户获取不到改为使用springsecurity的ContextHolder
This commit is contained in:
parent
020c4a0a6d
commit
1ba802389b
@ -18,7 +18,7 @@ public class PipelineExecuteTest {
|
|||||||
// 执行pipeline
|
// 执行pipeline
|
||||||
@Test
|
@Test
|
||||||
public void executePipeline(){
|
public void executePipeline(){
|
||||||
pipelineExecutor.execute("716299522803896320", PiplineTriggerModeEnum.HAND);
|
pipelineExecutor.execute("716299522803896320", PiplineTriggerModeEnum.HAND,false);
|
||||||
}
|
}
|
||||||
// 获取pipeline执行状态
|
// 获取pipeline执行状态
|
||||||
@Test
|
@Test
|
||||||
@ -28,7 +28,7 @@ public class PipelineExecuteTest {
|
|||||||
@Test
|
@Test
|
||||||
public void taskSkipExecute(){
|
public void taskSkipExecute(){
|
||||||
// 这个流水线包含了故意报错的worker,可以验证跳过效果
|
// 这个流水线包含了故意报错的worker,可以验证跳过效果
|
||||||
pipelineExecutor.execute("718104543308681216",PiplineTriggerModeEnum.HAND);
|
pipelineExecutor.execute("718104543308681216",PiplineTriggerModeEnum.HAND,false);
|
||||||
}
|
}
|
||||||
@Test
|
@Test
|
||||||
public void taskSkipGetState(){
|
public void taskSkipGetState(){
|
||||||
|
Loading…
x
Reference in New Issue
Block a user