Compare commits
1 Commits
35d579819c
...
bcc57ac804
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
bcc57ac804 |
@@ -9,7 +9,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
||||
## [0.2.0] - 2025-09-25
|
||||
|
||||
### Added
|
||||
- reset after failure
|
||||
- print as well
|
||||
- add publish
|
||||
- add features for nats and postgres
|
||||
|
||||
@@ -144,10 +144,7 @@ impl BackendEdge for PostgresBackend {
|
||||
|
||||
let res = match res {
|
||||
Ok(res) => res,
|
||||
Err(e) => {
|
||||
self.revision.store(0, Ordering::Relaxed);
|
||||
|
||||
match &e {
|
||||
Err(e) => match &e {
|
||||
sqlx::Error::Database(database_error) => {
|
||||
if database_error.is_unique_violation() {
|
||||
anyhow::bail!("update conflict: another leader holds lock")
|
||||
@@ -158,8 +155,7 @@ impl BackendEdge for PostgresBackend {
|
||||
_ => {
|
||||
anyhow::bail!(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
};
|
||||
|
||||
match res {
|
||||
@@ -174,8 +170,6 @@ impl BackendEdge for PostgresBackend {
|
||||
// Only update our local revision if the update succeeded with our expected value
|
||||
self.revision.store(rec.revision as u64, Ordering::Relaxed);
|
||||
} else {
|
||||
self.revision.store(0, Ordering::Relaxed);
|
||||
|
||||
anyhow::bail!(
|
||||
"update conflict: expected value={}, revision={}, got value={}, revision={}",
|
||||
val.0.to_string(),
|
||||
@@ -213,8 +207,6 @@ impl BackendEdge for PostgresBackend {
|
||||
.await
|
||||
.context("failed to release lock, it will expire naturally")?;
|
||||
|
||||
self.revision.store(0, Ordering::Relaxed);
|
||||
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user