From 3eaac6aa836d4080877edb6b7a2a5922f07eb3b2 Mon Sep 17 00:00:00 2001 From: Drew DeVault Date: Wed, 18 Aug 2021 14:45:51 +0200 Subject: [PATCH] webhooks: test error from delivery attempt --- webhooks/queue.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/webhooks/queue.go b/webhooks/queue.go index 6e6e86bc05db6333dea41e3b08b803d0fe38e304..52be6857f22f160e32b0e915742e08d6a385267b 100644 --- a/webhooks/queue.go +++ b/webhooks/queue.go @@ -179,8 +179,7 @@ func (queue *WebhookQueue) queueStage2(ctx context.Context, } return work.NewTask(func(ctx context.Context) error { - queue.deliverPayload(ctx, webhook, headers, payload, deliveryID) - return nil + return queue.deliverPayload(ctx, webhook, headers, payload, deliveryID) }).Retries(5).After(func(ctx context.Context, task *work.Task) { if task.Result() == nil { log.Printf("%s: webhook delivery complete after %d attempts",