Compare commits

1 Commits

Author SHA1 Message Date
cuddle-please
bcc57ac804 chore(release): 0.2.0
All checks were successful
continuous-integration/drone/push Build is passing
2025-09-25 08:23:18 +00:00
2 changed files with 9 additions and 18 deletions

View File

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

View File

@@ -144,22 +144,18 @@ impl BackendEdge for PostgresBackend {
let res = match res {
Ok(res) => res,
Err(e) => {
self.revision.store(0, Ordering::Relaxed);
match &e {
sqlx::Error::Database(database_error) => {
if database_error.is_unique_violation() {
anyhow::bail!("update conflict: another leader holds lock")
} else {
anyhow::bail!(e);
}
}
_ => {
Err(e) => match &e {
sqlx::Error::Database(database_error) => {
if database_error.is_unique_violation() {
anyhow::bail!("update conflict: another leader holds lock")
} else {
anyhow::bail!(e);
}
}
}
_ => {
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(())
}
}