fix: LockIDNotificationsReportGenerator

mtojek · mtojek · commit 5911ca945b22 · 2024-09-13T14:54:13.000+02:00
diff --git a/coderd/database/lock.go b/coderd/database/lock.go
@@ -10,7 +10,7 @@ const (
 	LockIDEnterpriseDeploymentSetup
 	LockIDDBRollup
 	LockIDDBPurge
-	LockIDReportGenerator
+	LockIDNotificationsReportGenerator
 )
 
 // GenLockID generates a unique and consistent lock ID from a given string.
diff --git a/coderd/notifications/reports/generator.go b/coderd/notifications/reports/generator.go
@@ -42,7 +42,7 @@ func NewReportGenerator(ctx context.Context, logger slog.Logger, db database.Sto
 		// Start a transaction to grab advisory lock, we don't want to run generator jobs at the same time (multiple replicas).
 		if err := db.InTx(func(tx database.Store) error {
 			// Acquire a lock to ensure that only one instance of the generator is running at a time.
-			ok, err := tx.TryAcquireLock(ctx, database.LockIDReportGenerator)
+			ok, err := tx.TryAcquireLock(ctx, database.LockIDNotificationsReportGenerator)
 			if err != nil {
 				return err
 			}

Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@ const (`
`10`	`10`	`LockIDEnterpriseDeploymentSetup`
`11`	`11`	`LockIDDBRollup`
`12`	`12`	`LockIDDBPurge`
`13`		`- LockIDReportGenerator`
	`13`	`+ LockIDNotificationsReportGenerator`
`14`	`14`	`)`
`15`	`15`
`16`	`16`	`// GenLockID generates a unique and consistent lock ID from a given string.`
Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ func NewReportGenerator(ctx context.Context, logger slog.Logger, db database.Sto`
`42`	`42`	`// Start a transaction to grab advisory lock, we don't want to run generator jobs at the same time (multiple replicas).`
`43`	`43`	`if err := db.InTx(func(tx database.Store) error {`
`44`	`44`	`// Acquire a lock to ensure that only one instance of the generator is running at a time.`
`45`		`- ok, err := tx.TryAcquireLock(ctx, database.LockIDReportGenerator)`
	`45`	`+ ok, err := tx.TryAcquireLock(ctx, database.LockIDNotificationsReportGenerator)`
`46`	`46`	`if err != nil {`
`47`	`47`	`return err`
`48`	`48`	`}`