Merge pull request #725 from Icinga/wrong-number-xdel-args

`history.Sync`: Don't operate on closed channel
Icinga · Apr 2, 2024 · 2826af4 · 2826af4
2 parents 51e5434 + ce56dff
commit 2826af4
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/icingadb/history/sync.go b/pkg/icingadb/history/sync.go
@@ -144,7 +144,11 @@ func (s Sync) deleteFromRedis(ctx context.Context, key string, input <-chan redi
 	stream := "icinga:history:stream:" + key
 	for {
 		select {
-		case bulk := <-bulks:
+		case bulk, ok := <-bulks:
+			if !ok {
+				return nil
+			}
+
 			ids := make([]string, len(bulk))
 			for i := range bulk {
 				ids[i] = bulk[i].ID