From 443c58eb39bb7c06f2a4634101eb926adad789d9 Mon Sep 17 00:00:00 2001 From: Dakota Paasman <122491662+dpaasman00@users.noreply.github.com> Date: Thu, 12 Sep 2024 14:49:39 -0400 Subject: [PATCH] fix: Call shutdown on storage extension (#1855) call shutdown on storage extension --- receiver/m365receiver/logs.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/receiver/m365receiver/logs.go b/receiver/m365receiver/logs.go index ffd8ddb96..a0bcdf2c8 100644 --- a/receiver/m365receiver/logs.go +++ b/receiver/m365receiver/logs.go @@ -140,7 +140,13 @@ func (l *m365LogsReceiver) Shutdown(ctx context.Context) error { l.cancel() } l.wg.Wait() - return l.checkpoint(ctx) + + err := l.checkpoint(ctx) + if err != nil { + l.logger.Error("failed checkpoint", zap.Error(err)) + } + + return l.storageClient.Close(ctx) } // spins a go routine at each poll interval to go get logs