Skip to content

N
nebula
Commit ac5843ca authored by Hamdi Allam's avatar Hamdi Allam
Browse files
Options

semgrep

parent f11dbe30
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
indexer/processor/processor.go
View file @ ac5843ca
...@@ -52,8 +52,9 @@ func (p processor) Start() { ...@@ -52,8 +52,9 @@ func (p processor) Start() {
return p.processFn(db, headers) return p.processFn(db, headers)
}) })
// TODO(DX-79) if processFn failed, the next poll should retry starting from this same batch of headers
if err != nil { if err != nil {
// TODO(DX-79) next poll should retry starting from this same batch of headers
batchLog.Info("unable to index batch", "err", err) batchLog.Info("unable to index batch", "err", err)
panic(err) panic(err)
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment