packages feed

keiro-pgmq 0.21.0.0 → 0.22.0.0

raw patch · 3 files changed

+38/−17 lines, 3 filesdep ~keiro-coredep ~keiro-test-supportdep ~pgmq-configPVP ok

version bump matches the API change (PVP)

Dependency ranges changed: keiro-core, keiro-test-support, pgmq-config, pgmq-core, pgmq-effectful, pgmq-hasql, pgmq-migration, shibuya-core, shibuya-pgmq-adapter

API changes (from Hackage documentation)

Files

CHANGELOG.md view
@@ -6,6 +6,25 @@  ## [Unreleased] +## 0.22.0.0 — 2026-10-27++### Breaking Changes++- Require [Shibuya Core](mori://shinzui/shibuya/packages/shibuya-core)+  `^>=0.12.0.0`, [the PGMQ adapter](mori://shinzui/shibuya-pgmq-adapter/packages/shibuya-pgmq-adapter)+  `^>=0.18.0.0`, and the [PGMQ family](mori://shinzui/pgmq-hs)+  `>=0.7.0.0 && <0.8`. Custom PGMQ interpreters and exhaustive+  reconciliation-action matches must handle the new inspection operations and+  refusal constructors; remove conflicting orphan JSON instances. Apply PGMQ+  migration 0007 before queue traffic; partitioned queues require polling.++### Other Changes++- Construct worker configuration from `defaultAppConfig` so the new+  metrics-detail field receives its default. Adapter-produced DLQ envelopes+  now include `original_queue`; existing Keiro DLQ operations accept the+  additional metadata.+ ## 0.21.0.0 — 2026-10-14  ### Other Changes
keiro-pgmq.cabal view
@@ -1,6 +1,6 @@ cabal-version: 3.0 name: keiro-pgmq-version: 0.21.0.0+version: 0.22.0.0 synopsis: PostgreSQL job-queue (PGMQ) integration for Keiro description:   A typed background-job queue for Keiro applications on top of PGMQ (the@@ -65,13 +65,13 @@     hasql >=1.10 && <1.11,     hasql-pool >=1.2 && <1.5,     hs-opentelemetry-api >=1.0 && <1.1,-    keiro-core ^>=0.21.0.0,-    pgmq-config >=0.6.1.1 && <0.7,-    pgmq-core >=0.6.1.1 && <0.7,-    pgmq-effectful >=0.6.1.1 && <0.7,-    pgmq-hasql >=0.6.1.1 && <0.7,-    shibuya-core ^>=0.10.0.1,-    shibuya-pgmq-adapter ^>=0.16.1.0,+    keiro-core ^>=0.22.0.0,+    pgmq-config >=0.7.0.0 && <0.8,+    pgmq-core >=0.7.0.0 && <0.8,+    pgmq-effectful >=0.7.0.0 && <0.8,+    pgmq-hasql >=0.7.0.0 && <0.8,+    shibuya-core ^>=0.12.0.0,+    shibuya-pgmq-adapter ^>=0.18.0.0,     streamly-core >=0.3 && <0.4,     text >=2.1 && <2.2,     time >=1.12 && <1.15,@@ -97,13 +97,13 @@     hs-opentelemetry-propagator-w3c >=1.0 && <1.1,     hs-opentelemetry-sdk >=1.0 && <1.1,     hspec >=2.11,-    keiro-core ^>=0.21.0.0,+    keiro-core ^>=0.22.0.0,     keiro-pgmq,-    keiro-test-support ^>=0.21.0.0,-    pgmq-config >=0.6.1.1 && <0.7,-    pgmq-core >=0.6.1.1 && <0.7,-    pgmq-effectful >=0.6.1.1 && <0.7,-    pgmq-migration >=0.6.1.1 && <0.7,-    shibuya-core ^>=0.10.0.1,-    shibuya-pgmq-adapter ^>=0.16.1.0,+    keiro-test-support ^>=0.22.0.0,+    pgmq-config >=0.7.0.0 && <0.8,+    pgmq-core >=0.7.0.0 && <0.8,+    pgmq-effectful >=0.7.0.0 && <0.8,+    pgmq-migration >=0.7.0.0 && <0.8,+    shibuya-core ^>=0.12.0.0,+    shibuya-pgmq-adapter ^>=0.18.0.0,     text >=2.1 && <2.2,
src/Keiro/PGMQ/Job.hs view
@@ -169,6 +169,7 @@     ProcessorId (..),     QueueProcessor,     SupervisionStrategy,+    defaultAppConfig,     mkProcessor,     runApp,   )@@ -182,6 +183,7 @@ import "shibuya-core" Shibuya.Core.Ingested qualified as Shibuya import "shibuya-core" Shibuya.Core.Lease (Lease (..)) import "shibuya-core" Shibuya.Core.Types (Attempt (..), Envelope (..))+ -- Qualified only for 'unMessageId': shibuya's @MessageId@ type name would -- otherwise collide with @Pgmq.Effectful@'s, which the producer signatures use. import "shibuya-core" Shibuya.Core.Types qualified as ShibuyaTypes@@ -895,7 +897,7 @@   Eff es (Either AppError (AppHandle es)) runJobWorkers strategy inboxSize procs = do   ps <- sequence procs-  runApp AppConfig {strategy = strategy, inboxSize = max 1 inboxSize} ps+  runApp defaultAppConfig {strategy = strategy, inboxSize = max 1 inboxSize} ps  -- | Open the one-shot equivalent of shibuya's per-message processing span. --