diff --git a/business/jxutils/tasksch/sequence_task.go b/business/jxutils/tasksch/sequence_task.go index 7bcd3faac..1ab500466 100644 --- a/business/jxutils/tasksch/sequence_task.go +++ b/business/jxutils/tasksch/sequence_task.go @@ -19,10 +19,14 @@ type SeqTask struct { } func NewSeqTask(taskName string, ctx *jxcontext.Context, worker SeqWorkFunc, stepCount int, params ...interface{}) *SeqTask { + return NewSeqTask2(taskName, ctx, false, worker, stepCount, params...) +} + +func NewSeqTask2(taskName string, ctx *jxcontext.Context, isContinueWhenError bool, worker SeqWorkFunc, stepCount int, params ...interface{}) *SeqTask { task := &SeqTask{ worker: worker, } - task.Init(1, 1, false, params, taskName, ctx, stepCount, stepCount) + task.Init(1, 1, isContinueWhenError, params, taskName, ctx, stepCount, stepCount) return task }