aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-10 11:44:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

remove unnecessary change

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-08-06 22:09:20 +04:00
parent ae0dff6a55
commit bfacc141b0
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/turso-sync/src/database_tape.rs
View File

@@ -60,7 +60,7 @@ impl DatabaseTape {
opts: DatabaseChangesIteratorOpts,
) -> Result<DatabaseChangesIterator> {
tracing::debug!("opening changes iterator with options {:?}", opts);
let conn = self.inner.connect()?;
let conn = self.connect().await?;
let query = opts.mode.query(&self.cdc_table, opts.batch_size);
let query_stmt = conn.prepare(&query).await?;
Ok(DatabaseChangesIterator {