fix: Call shutdown on storage extension (#1855)

call shutdown on storage extension
observIQ · Sep 12, 2024 · 1bbab5e · 1bbab5e
1 parent b0882b6
commit 1bbab5e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git 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