Skip to content

Commit

Permalink
refactor(ARCO-319): Set maxBlockProcessingDuration in e2e test to 2s …
Browse files Browse the repository at this point in the history
…so that all gaps get closed before e2e tests start
  • Loading branch information
boecklim committed Jan 16, 2025
1 parent 6f3e2e8 commit 480cade
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions internal/blocktx/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@ const (
registerTxsBatchSizeDefault = 100
registerRequestTxBatchSizeDefault = 100
waitForBlockProcessing = 5 * time.Minute
lockTime = 5 * time.Minute
parallellism = 5
)

Expand Down Expand Up @@ -166,7 +165,7 @@ func (p *Processor) StartBlockRequesting() {
peer := req.Peer

// lock block for the current instance to process
processedBy, err := p.store.SetBlockProcessing(p.ctx, hash, p.hostname, lockTime, maxBlocksInProgress)
processedBy, err := p.store.SetBlockProcessing(p.ctx, hash, p.hostname, p.maxBlockProcessingDuration, maxBlocksInProgress)
if err != nil {
if errors.Is(err, store.ErrBlockProcessingMaximumReached) {
p.logger.Debug("block processing maximum reached", slog.String("hash", hash.String()), slog.String("processed_by", processedBy))
Expand Down

0 comments on commit 480cade

Please sign in to comment.