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<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 {