Non-Blocking write to wakeup channel (#6007)

treeverse · Jun 1, 2023 · 1e12dca · 1e12dca
1 parent c47aade
commit 1e12dca
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/graveler/staging/manager.go b/pkg/graveler/staging/manager.go
@@ -113,7 +113,11 @@ func (m *Manager) Drop(ctx context.Context, st graveler.StagingToken) error {
 
 func (m *Manager) DropAsync(ctx context.Context, st graveler.StagingToken) error {
 	err := m.kvStore.Set(ctx, []byte(graveler.CleanupTokensPartition()), []byte(st), []byte("stub-value"))
-	m.wakeup <- cleanTokens
+	select {
+	case m.wakeup <- cleanTokens:
+	default:
+		m.log.Debug("wakeup channel is full, skipping wakeup")
+	}
 	return err
 }