Prevent panicking when SQS consumer is disabled (#50646)

gravitational · Dec 31, 2024 · 10115c0 · 10115c0
1 parent 3164d21
commit 10115c0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/events/athena/athena.go b/lib/events/athena/athena.go
@@ -543,7 +543,11 @@ func (l *Log) SearchSessionEvents(ctx context.Context, req events.SearchSessionE
 }
 
 func (l *Log) Close() error {
-	return trace.Wrap(l.consumerCloser.Close())
+	// consumerCloser is nil when consumer is disabled.
+	if l.consumerCloser != nil {
+		return trace.Wrap(l.consumerCloser.Close())
+	}
+	return nil
 }
 
 func (l *Log) IsConsumerDisabled() bool {