diff --git a/ingest/usecase/plugins/orderbookfiller/ordebook_filler_ingest_plugin.go b/ingest/usecase/plugins/orderbookfiller/ordebook_filler_ingest_plugin.go index b334f17ac..065d5c625 100644 --- a/ingest/usecase/plugins/orderbookfiller/ordebook_filler_ingest_plugin.go +++ b/ingest/usecase/plugins/orderbookfiller/ordebook_filler_ingest_plugin.go @@ -168,7 +168,6 @@ func (o *orderbookFillerIngestPlugin) ProcessEndBlock(ctx context.Context, block blockGasPrice := blockCtx.GetGasPrice() if err := o.tryFill(ctx, txCtx, blockGasPrice); err != nil { - if len(originalMsgs) == 1 { o.logger.Error("failed to fill", zap.Error(err)) return err @@ -177,7 +176,6 @@ func (o *orderbookFillerIngestPlugin) ProcessEndBlock(ctx context.Context, block // Try to fill each message indivdually for _, msg := range originalMsgs { - // Create a new transaction context for each message curTxCtx := txctx.New()