chore(release): 0.1.0

CHANGELOG.md

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

internal/scheduler/scheduler.go

@@ -67,8 +67,13 @@ func (s *Scheduler) acquireLeader(ctx context.Context) (bool, error) {
 		case <-ctx.Done():
 			return false, nil
 		default:
+			db, err := s.db.Acquire(ctx)
+			if err != nil {
+				return false, fmt.Errorf("failed to acquire db connection: %w", err)
+			}
+
 			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) {
 					return false, nil
 				}