Use adjusted 'UpsertStreamed' from icinga-go-library

Icinga · Nov 24, 2023 · 089e43e · 089e43e
1 parent 771ef0a
commit 089e43e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()