diff --git a/components/app/app.go b/components/app/app.go index 49155c4..0338cc3 100644 --- a/components/app/app.go +++ b/components/app/app.go @@ -13,7 +13,7 @@ var ( Name = "inx-faucet" // Version of the app. - Version = "2.0.0-alpha.3" + Version = "2.0.0-alpha.4" ) func App() *app.App { diff --git a/pkg/faucet/faucet.go b/pkg/faucet/faucet.go index d3b0363..6e24ea0 100644 --- a/pkg/faucet/faucet.go +++ b/pkg/faucet/faucet.go @@ -785,6 +785,8 @@ func (f *Faucet) collectRequestsAndSendFaucetBlock(ctx context.Context) error { } f.logSoftError(err) } + // readd the all collected requests back to the queue + f.readdRequestsWithoutLocking(batchedRequests) return nil } @@ -797,6 +799,7 @@ func (f *Faucet) collectRequestsAndSendFaucetBlock(ctx context.Context) error { // => stop the faucet return err } + // readd the non-processed requests back to the queue f.readdRequestsWithoutLocking(processableRequests) f.logSoftError(err) }