Skip to content

Commit ab5d8ba

Browse files
committed
fix: pass context.Background() to NewS2Storage so S2 pipeline outlives signal cancellation
1 parent c6467b3 commit ab5d8ba

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

server/cmd/api/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ func main() {
106106
var storageWriter *events.StorageWriter
107107
if config.S2Basin != "" && config.S2AccessToken != "" && config.S2Stream != "" {
108108
slogger.Info("S2 storage enabled", "basin", config.S2Basin, "stream", config.S2Stream)
109-
s2stor, err := events.NewS2Storage(ctx, config.S2Basin, config.S2AccessToken, config.S2Stream, events.S2Config{}, slogger)
109+
s2stor, err := events.NewS2Storage(context.Background(), config.S2Basin, config.S2AccessToken, config.S2Stream, events.S2Config{}, slogger)
110110
if err != nil {
111111
slogger.Error("failed to create S2 storage", "err", err)
112112
os.Exit(1)

0 commit comments

Comments
 (0)