TransformJdSpu2Sku中序列任务也可以是isContinueWhenError

2019-12-05 17:09:50 +08:00
parent a2f80aa60e
commit 0a69bb7522
1 changed files with 1 additions and 1 deletions
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -631,7 +631,7 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA
 		return "", fmt.Errorf("待转换的skuName为空")
 	}
 	batchSize := 40
-	rootTask := tasksch.NewSeqTask("TransformJdSpu2Sku", ctx,
+	rootTask := tasksch.NewSeqTask2("TransformJdSpu2Sku", ctx, isContinueWhenError,
 		func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
 			var (
 				locker sync.Mutex