Skip to content

Commit 20bd215

Browse files
committed
feat: conditionally clear attestor queue in Redis when push is disabled
1 parent 13f4a6f commit 20bd215

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

cmd/main.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,9 @@ func main() {
5656
defer cancel()
5757

5858
var wg sync.WaitGroup
59-
59+
if !config.SettingsObj.AttestorQueuePushEnabled {
60+
redis.Delete(ctx, "attestorQueue")
61+
}
6062
// Run initial cleanup for all data markets
6163
for _, dataMarketAddress := range config.SettingsObj.DataMarketAddresses {
6264
wg.Add(1)

0 commit comments

Comments
 (0)