From bfacc141b0981a4370bfa1c6cae10b7b87a19e68 Mon Sep 17 00:00:00 2001 From: Nikita Sivukhin Date: Wed, 6 Aug 2025 22:09:20 +0400 Subject: [PATCH] remove unnecessary change --- packages/turso-sync/src/database_tape.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/turso-sync/src/database_tape.rs b/packages/turso-sync/src/database_tape.rs index 2438ce152..0aa513ae9 100644 --- a/packages/turso-sync/src/database_tape.rs +++ b/packages/turso-sync/src/database_tape.rs @@ -60,7 +60,7 @@ impl DatabaseTape { opts: DatabaseChangesIteratorOpts, ) -> Result { 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 {