From 33115ff9179a53316e233b0c82fe8a03ea989579 Mon Sep 17 00:00:00 2001 From: mario Date: Tue, 28 Oct 2025 15:30:02 +0700 Subject: [PATCH] Fix PostgreSQL DelayedSubscriber timezone query bug (issue https://github.com/ThreeDotsLabs/watermill/issues/631) --- pkg/sql/delayed_postgresql.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/sql/delayed_postgresql.go b/pkg/sql/delayed_postgresql.go index 4e9c361..9428969 100644 --- a/pkg/sql/delayed_postgresql.go +++ b/pkg/sql/delayed_postgresql.go @@ -84,7 +84,7 @@ func (c *DelayedPostgreSQLSubscriberConfig) setDefaults() { func NewDelayedPostgreSQLSubscriber(db Beginner, config DelayedPostgreSQLSubscriberConfig) (message.Subscriber, error) { config.setDefaults() - where := fmt.Sprintf("(metadata->>'%v')::timestamptz < NOW() AT TIME ZONE 'UTC'", delay.DelayedUntilKey) + where := fmt.Sprintf("(metadata->>'%v')::timestamptz < NOW()", delay.DelayedUntilKey) if config.AllowNoDelay { where += fmt.Sprintf(` OR (metadata->>'%s') IS NULL`, delay.DelayedUntilKey)