We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 557ff5f commit 725fa1eCopy full SHA for 725fa1e
src/Share/BackgroundJobs/Webhooks/Worker.hs
@@ -103,7 +103,7 @@ worker scope = do
103
toIO <- UnliftIO.askRunInIO
104
-- Need to unlift so we can use this in transactions
105
let tryWebhookIO eventData webhookId = toIO $ tryWebhook eventData webhookId
106
- mayResult <- Metrics.recordWebhookSendingDuration $ PG.runTransaction $ runMaybeT $ do
+ mayResult <- Metrics.recordWebhookSendingDuration $ PG.runTransactionMode PG.ReadCommitted PG.ReadWrite $ runMaybeT $ do
107
webhookInfo@(eventId, webhookId) <- MaybeT WQ.getUnsentWebhook
108
mayErr <- lift $ attemptWebhookSend authZReceipt tryWebhookIO eventId webhookId
109
pure (mayErr, webhookInfo)
0 commit comments