Update

taikoxyz · Mar 18, 2024 · f36d1c0 · f36d1c0
1 parent c8da85b
commit f36d1c0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/packages/relayer/indexer/indexer.go b/packages/relayer/indexer/indexer.go
@@ -224,7 +224,7 @@ func (i *Indexer) Start() error {
 				slog.Error("filter failed, will retry", "error", err)
 			}
 			return err
-		}, backoff.NewConstantBackOff(5*time.Second)); err != nil {
+		}, backoff.WithContext(backoff.NewConstantBackOff(5*time.Second), i.ctx)); err != nil {
 			slog.Error("error after retrying filter with backoff", "error", err)
 		}
 	}()
@@ -236,7 +236,7 @@ func (i *Indexer) Start() error {
 				slog.Error("scanBlocks failed, will retry", "error", err)
 			}
 			return err
-		}, backoff.NewConstantBackOff(5*time.Second)); err != nil {
+		}, backoff.WithContext(backoff.NewConstantBackOff(5*time.Second), i.ctx)); err != nil {
 			slog.Error("scan blocks backoff retry", "error", err)
 		}
 	}()
@@ -248,7 +248,7 @@ func (i *Indexer) Start() error {
 				slog.Error("i.queue.Notify failed, will retry", "error", err)
 			}
 			return err
-		}, backoff.NewConstantBackOff(5*time.Second)); err != nil {
+		}, backoff.WithContext(backoff.NewConstantBackOff(5*time.Second), i.ctx)); err != nil {
 			slog.Error("i.queue.Notify backoff retry", "error", err)
 		}
 	}()