File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -119,7 +119,7 @@ func (f *Flow) Start() {
119119
120120 if workInfo == nil || workInfo .Work == nil {
121121 if ! hasMore {
122- log .Info ("work producer get work completed" )
122+ log .Debug ("work producer get work completed" )
123123 break
124124 } else {
125125 log .Info ("work producer get work fail: work in empty" )
@@ -198,14 +198,14 @@ func (f *Flow) Start() {
198198
199199 workCount := len (workList )
200200
201- log .InfoF ("work consumer get works, count:%d" , workCount )
201+ log .DebugF ("work consumer get works, count:%d" , workCount )
202202
203203 _ = f .limitAcquire (workCount )
204204 // workRecordList 有数据则长度和 workList 长度相同
205205 workRecordList , workErr := worker .DoWork (workList )
206206 f .limitRelease (workCount )
207207
208- log .InfoF ("work consumer handle works, count:%d error:%+v" , workCount , workErr )
208+ log .DebugF ("work consumer handle works, count:%d error:%+v" , workCount , workErr )
209209
210210 if len (workRecordList ) == 0 && workErr != nil {
211211 log .ErrorF ("Do Worker Error:%+v" , workErr )
You can’t perform that action at this time.
0 commit comments