From 089e43e1180a65a159151af2353a8fd34197f5df Mon Sep 17 00:00:00 2001 From: Johannes Rauh Date: Fri, 24 Nov 2023 14:30:55 +0100 Subject: [PATCH] Use adjusted 'UpsertStreamed' from icinga-go-library --- pkg/sync/logs.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/sync/logs.go b/pkg/sync/logs.go index 0b0eca45..b5183c20 100644 --- a/pkg/sync/logs.go +++ b/pkg/sync/logs.go @@ -224,7 +224,7 @@ func (ls *LogSync) Run(ctx context.Context) error { }) g.Go(func() error { - return ls.db.UpsertStreamedWithStatement(ctx, upserts, upsertStmt, 5) + return ls.db.UpsertStreamed(ctx, upserts, database.WithStatement(upsertStmt, 5)) }) return g.Wait()