Prevent panicking when SQS consumer is disabled (#50643)

gravitational · Dec 31, 2024 · b44d19b · b44d19b
1 parent 909cc20
commit b44d19b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/events/athena/athena.go b/lib/events/athena/athena.go
@@ -538,7 +538,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 {