Compare commits

..

2 Commits

Author SHA1 Message Date
cuddle-please
847ef923bf chore(release): 0.1.0 2025-01-17 20:31:17 +00:00
54aa310583
fix: use dedicated connection for scheduler process 2025-01-17 21:30:56 +01:00
2 changed files with 7 additions and 1 deletions
CHANGELOG.md
internal/scheduler

@ -19,6 +19,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- add default - add default
### Fixed ### Fixed
- use dedicated connection for scheduler process
- *(deps)* update module gitlab.com/greyxor/slogor to v1.6.1 - *(deps)* update module gitlab.com/greyxor/slogor to v1.6.1
- orbis demo - orbis demo

@ -67,8 +67,13 @@ func (s *Scheduler) acquireLeader(ctx context.Context) (bool, error) {
case <-ctx.Done(): case <-ctx.Done():
return false, nil return false, nil
default: default:
db, err := s.db.Acquire(ctx)
if err != nil {
return false, fmt.Errorf("failed to acquire db connection: %w", err)
}
var acquiredLock bool var acquiredLock bool
if err := s.db.QueryRow(ctx, "SELECT pg_try_advisory_lock(1234)").Scan(&acquiredLock); err != nil { if err := db.QueryRow(ctx, "SELECT pg_try_advisory_lock(1234)").Scan(&acquiredLock); err != nil {
if errors.Is(err, pgx.ErrNoRows) { if errors.Is(err, pgx.ErrNoRows) {
return false, nil return false, nil
} }