From 0a69bb7522fa17d952722ae54331c36a9ee69fec Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 5 Dec 2019 17:09:50 +0800 Subject: [PATCH] =?UTF-8?q?TransformJdSpu2Sku=E4=B8=AD=E5=BA=8F=E5=88=97?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=B9=9F=E5=8F=AF=E4=BB=A5=E6=98=AFisContinu?= =?UTF-8?q?eWhenError?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/tempop/tempop.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 34ce3f737..d13670c09 100644 --- 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