diff --git a/pkg/sync/logs.go b/pkg/sync/logs.go
index 0b0eca4..d95f8f6 100644
--- a/pkg/sync/logs.go
+++ b/pkg/sync/logs.go
@@ -143,7 +143,7 @@ func (ls *LogSync) MaintainList(ctx context.Context, addChannel <-chan contracts
 	})
 
 	g.Go(func() error {
-		return ls.db.DeleteStreamedByField(ctx, &schema.Log{}, "reference_id", deletes)
+		return ls.db.DeleteStreamed(ctx, &schema.Log{}, deletes, database.ByColumn("reference_id"))
 	})
 
 	return g.Wait()
@@ -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()