Skip to content

Commit e26c90d

Browse files
AlfandiMariomario
andauthored
Fix PostgreSQL DelayedSubscriber timezone query bug (issue ThreeDotsLabs/watermill#631) (#53)
Co-authored-by: mario <dev.mario@sismedika.com>
1 parent 3b87c0a commit e26c90d

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

pkg/sql/delayed_postgresql.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ func (c *DelayedPostgreSQLSubscriberConfig) setDefaults() {
8484
func NewDelayedPostgreSQLSubscriber(db Beginner, config DelayedPostgreSQLSubscriberConfig) (message.Subscriber, error) {
8585
config.setDefaults()
8686

87-
where := fmt.Sprintf("(metadata->>'%v')::timestamptz < NOW() AT TIME ZONE 'UTC'", delay.DelayedUntilKey)
87+
where := fmt.Sprintf("(metadata->>'%v')::timestamptz < NOW()", delay.DelayedUntilKey)
8888

8989
if config.AllowNoDelay {
9090
where += fmt.Sprintf(` OR (metadata->>'%s') IS NULL`, delay.DelayedUntilKey)

0 commit comments

Comments
 (0)