From cb34c43ef470524ef660b6653f3cb252bf2c81ee Mon Sep 17 00:00:00 2001 From: Eli Ribble Date: Thu, 19 Mar 2026 21:29:20 +0000 Subject: [PATCH] Improve error messages on notify failures --- platform/start.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/platform/start.go b/platform/start.go index 130a1ca1..34abec84 100644 --- a/platform/start.go +++ b/platform/start.go @@ -156,7 +156,7 @@ func listenAndDoOneJob(ctx context.Context) error { _, err = conn.Exec(ctx, "LISTEN new_job") if err != nil { //if !pgconn.Timeout(err) { - return fmt.Errorf("failed to listen to outbound_email_queued: %w", err) + return fmt.Errorf("failed to execute 'LISTEN new_job': %w", err) } for { @@ -164,7 +164,7 @@ func listenAndDoOneJob(ctx context.Context) error { notification, err := conn.Conn().WaitForNotification(ctx) if err != nil { //if !pgconn.Timeout(err) { - return fmt.Errorf("failed while waiting for notification of outbound_email_queued") + return fmt.Errorf("failed while waiting for notification of new job: %w", err) } job_id, err := strconv.Atoi(notification.Payload)