Skip to content

Commit

Permalink
Upgrade sqlx to 0.7.1 (#48)
Browse files Browse the repository at this point in the history
  • Loading branch information
qwfy committed Oct 11, 2023
1 parent 75e12ba commit 5e4f160
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
4 changes: 2 additions & 2 deletions src/runner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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(())
Expand All @@ -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(())
}
Expand Down

0 comments on commit 5e4f160

Please sign in to comment.