diff --git a/cmd/state/exec22/txtask.go b/cmd/state/exec22/txtask.go index 590a2b432..a4831d96a 100644 --- a/cmd/state/exec22/txtask.go +++ b/cmd/state/exec22/txtask.go @@ -160,7 +160,6 @@ func (q *QueueWithRetry) ReTry(t *TxTask) { // Next - blocks until new task available func (q *QueueWithRetry) Next(ctx context.Context) (*TxTask, bool) { - log.Warn("[dbg] before next", "newTasks", q.NewTasksLen(), "retires", q.RetriesLen()) task, ok := q.popNoWait() if ok { return task, true @@ -331,7 +330,7 @@ func (q *ResultsQueue) Drain(ctx context.Context) error { q.Lock() msg := []string{} for _, t := range *(q.results) { - if t.TxNum > 9299153 { + if t.TxNum > 9300_000 { msg = append(msg, fmt.Sprintf("%d", t.TxNum)) } } diff --git a/cmd/state/exec3/state.go b/cmd/state/exec3/state.go index 13ef8cec2..932c1f413 100644 --- a/cmd/state/exec3/state.go +++ b/cmd/state/exec3/state.go @@ -104,6 +104,9 @@ func (rw *Worker) Run() error { if err := rw.resultCh.Add(rw.ctx, txTask); err != nil { return err } + if txTask.TxNum > 9300_000 { + log.Warn("[dbg] before next", "newTasks", rw.in.NewTasksLen(), "retires", rw.in.RetriesLen()) + } } return nil }