diff --git a/CHANGELOG.md b/CHANGELOG.md index f0578d1d..d8e565bd 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Fixed - Ensure `ScheduledAt` is respected on `InsertManyTx`. [PR #121](https://github.com/riverqueue/river/pull/121). +- Fix typo in leadership resignation query to ensure faster new leader takeover. [PR #134](https://github.com/riverqueue/river/pull/134). ## [0.0.14] - 2023-12-13 diff --git a/internal/dbsqlc/river_leader.sql b/internal/dbsqlc/river_leader.sql index cef5b961..25e0f0d0 100644 --- a/internal/dbsqlc/river_leader.sql +++ b/internal/dbsqlc/river_leader.sql @@ -40,7 +40,7 @@ WITH currently_held_leaders AS ( ), notified_resignations AS ( SELECT - pg_notify('river_leaderhip', json_build_object('name', name, 'leader_id', leader_id, 'action', 'resigned')::text), + pg_notify('river_leadership', json_build_object('name', name, 'leader_id', leader_id, 'action', 'resigned')::text), currently_held_leaders.name FROM currently_held_leaders) diff --git a/internal/dbsqlc/river_leader.sql.go b/internal/dbsqlc/river_leader.sql.go index ffae88cd..fb82f0a7 100644 --- a/internal/dbsqlc/river_leader.sql.go +++ b/internal/dbsqlc/river_leader.sql.go @@ -80,7 +80,7 @@ WITH currently_held_leaders AS ( ), notified_resignations AS ( SELECT - pg_notify('river_leaderhip', json_build_object('name', name, 'leader_id', leader_id, 'action', 'resigned')::text), + pg_notify('river_leadership', json_build_object('name', name, 'leader_id', leader_id, 'action', 'resigned')::text), currently_held_leaders.name FROM currently_held_leaders)