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()