good morning!!!!

Skip to content
Snippets Groups Projects
Commit d259bb2d authored by alex.sharov's avatar alex.sharov
Browse files

return err on interruption

parent 3d52a22f
No related branches found
No related tags found
No related merge requests found
......@@ -8,6 +8,7 @@ import (
"time"
"unsafe"
"github.com/ledgerwatch/erigon-lib/common"
"github.com/ledgerwatch/erigon-lib/etl"
"github.com/ledgerwatch/erigon-lib/kv"
"github.com/ledgerwatch/erigon/ethdb"
......@@ -246,7 +247,7 @@ func (m *mapmutation) doCommit(tx kv.RwTx) error {
log.Info("Write to db", "progress", progress, "current table", table)
tx.CollectMetrics()
case <-m.quit:
return nil
return common.ErrStopped
}
}
if err := collector.Load(m.db, table, etl.IdentityLoadFunc, etl.TransformArgs{Quit: m.quit}); err != nil {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment