Version Packages

Author: github-actions[bot]

.changeset/real-snakes-enjoy.md

@@ -1,5 +1,63 @@
 # @effect/workflow
 
+## 0.13.1
+
+### Patch Changes
+
+- [#5821](https://github.com/Effect-TS/effect/pull/5821) [`2519056`](https://github.com/Effect-TS/effect/commit/2519056cb3aabd3dfffa0c874dabd74e2ad98655) Thanks @tim-smart! - add DurableQueue module
+
+  A `DurableQueue` wraps a `PersistedQueue`, providing a way to wait for items
+  to finish processing using a `DurableDeferred`.
+
+  ```ts
+  import { DurableQueue, Workflow } from "@effect/workflow"
+  import { Effect, Schema } from "effect"
+
+  // Define a DurableQueue that can be used to derive workers and offer items for
+  // processing.
+  const ApiQueue = DurableQueue.make({
+    name: "ApiQueue",
+    payload: {
+      id: Schema.String
+    },
+    success: Schema.Void,
+    error: Schema.Never,
+    idempotencyKey(payload) {
+      return payload.id
+    }
+  })
+
+  const MyWorkflow = Workflow.make({
+    name: "MyWorkflow",
+    payload: {
+      id: Schema.String
+    },
+    idempotencyKey: ({ id }) => id
+  })
+
+  const MyWorkflowLayer = MyWorkflow.toLayer(
+    Effect.fn(function* () {
+      // Add an item to the DurableQueue defined above.
+      //
+      // When the worker has finished processing the item, the workflow will
+      // resume.
+      //
+      yield* DurableQueue.process(ApiQueue, { id: "api-call-1" })
+
+      yield* Effect.log("Workflow succeeded!")
+    })
+  )
+
+  // Define a worker layer that can process items from the DurableQueue.
+  const ApiWorker = DurableQueue.worker(
+    ApiQueue,
+    Effect.fn(function* ({ id }) {
+      yield* Effect.log(`Worker processing API call with id: ${id}`)
+    }),
+    { concurrency: 5 } // Process up to 5 items concurrently
+  )
+  ```
+
 ## 0.13.0
 
 ### Minor Changes

packages/workflow/CHANGELOG.md

@@ -1,7 +1,7 @@
 {
   "name": "@effect/workflow",
   "type": "module",
-  "version": "0.13.0",
+  "version": "0.13.1",
   "description": "Durable workflows for Effect",
   "publishConfig": {
     "access": "public",