update: more msg
This commit is contained in:
parent
f75e31ffbb
commit
486ffba682
@ -90,6 +90,7 @@ func executeData(ctx context.Context, input, output interfaces.DumpIO) error {
|
|||||||
err error
|
err error
|
||||||
lines []*interfaces.ESSource
|
lines []*interfaces.ESSource
|
||||||
succeed int
|
succeed int
|
||||||
|
total int
|
||||||
)
|
)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
@ -114,7 +115,9 @@ func executeData(ctx context.Context, input, output interfaces.DumpIO) error {
|
|||||||
return fmt.Errorf("cmd.run: got lines=%d, only succeed=%d", len(lines), succeed)
|
return fmt.Errorf("cmd.run: got lines=%d, only succeed=%d", len(lines), succeed)
|
||||||
}
|
}
|
||||||
|
|
||||||
logrus.Infof("Dump: %d docs succeed!!!", succeed)
|
total += succeed
|
||||||
|
|
||||||
|
logrus.Infof("Dump: succeed=%d total=%d docs succeed!!!", succeed, total)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user