Effect-TS/effect @effect/workflow@0.13.1

on GitHub

Patch Changes

• #5821 2519056 Thanks @tim-smart! - add DurableQueue module

  A DurableQueue wraps a PersistedQueue, providing a way to wait for items
  to finish processing using a DurableDeferred.

  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
  )

• Updated dependencies [ebfbbd6]:

  • @effect/platform@0.93.5