diff --git a/Cargo.toml b/Cargo.toml index 855f732..d35241c 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -15,7 +15,7 @@ members = ["sqlxmq_macros", "sqlxmq_stress"] # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html [dependencies] -sqlx = { version = "0.6.0", features = ["postgres", "chrono", "uuid"] } +sqlx = { version = "0.7.1", features = ["postgres", "chrono", "uuid"] } tokio = { version = "1.8.3", features = ["full"] } dotenv = "0.15.0" chrono = "0.4.19" diff --git a/src/runner.rs b/src/runner.rs index fcd27ab..85ddba5 100644 --- a/src/runner.rs +++ b/src/runner.rs @@ -142,7 +142,7 @@ impl CurrentJob { &mut self, mut tx: sqlx::Transaction<'_, Postgres>, ) -> Result<(), sqlx::Error> { - self.delete(&mut tx).await?; + self.delete(&mut *tx).await?; tx.commit().await?; self.stop_keep_alive().await; Ok(()) @@ -161,7 +161,7 @@ impl CurrentJob { mut tx: sqlx::Transaction<'_, Postgres>, checkpoint: &Checkpoint<'_>, ) -> Result<(), sqlx::Error> { - checkpoint.execute(self.id, &mut tx).await?; + checkpoint.execute(self.id, &mut *tx).await?; tx.commit().await?; Ok(()) }