---
id: TST-PFM-INT-010
title: worker
kind: integration
product_area: platform
module: integrations
revision: 1
status: draft
source_sha:
  services-platform: ad3f6a6582843008ed0f5a17b131878d15829af1
  macroservice-libraries: 54536a441935c6e09fdb7f96f0bec71c52ba4e03
  react-console: baf6dae382d6f41dce976c7f848667ccc37e076f
repository: macroservice-libraries
files:
  - packages/workflow-actions/src/tests/integration/worker.integration.spec.ts
implements: []
environment: local
implementation_state: implemented
latest_result: not-run
latest_run_at: null
latest_run_ref: null
conformance: not-verified
estimated_minutes: 5
isolation: >-
  Use the suite-owned database fixtures and its declared cleanup; prepare the test database before
  integration or lifecycle execution.
evidence:
  - 'macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts'
test_cases:
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#the
      dispatcher publishes one message per lane with its tenant and deletes the rows the queue accepted
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#a
      row the queue refused stays, and is offered again once its claim lapses
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#runs
      the lane through the executors and records completed with outputs and the external reference
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#re-reads
      the host’s facts at execution and passes earlier outputs to a later run
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#a
      transient failure puts the run back and stops the lane; the next delivery completes it and the next
      run
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#on
      the last receive, retry_then_attention records failed and raises the host’s attention; the lane
      goes on
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#on
      the last receive, retry_then_skip records skipped with the error and raises no attention
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#a
      skip run is never retried: its first failure is recorded skipped and the message is done
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#a
      refusal is final at once, with the executor’s own code: no retry
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#halt_batch:
      a final failure skips the rest of the lane
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#staff
      retry a failed run: the same run queued again, its lane offered again, completed by the next
      delivery
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#staff
      skip a failed run with a reason; a skip without one is refused, and a completed run is neither
      retried nor skipped
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#reports
      a message that is not one of ours as unroutable, for the dead-letter queue
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#a
      run that finishes after its instance was cancelled records instance_cancelled: true; one of an open
      instance does not
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#failOverdueRuns
      fails a run running past the deadline with executor_timeout and applies on_failure; a younger one
      waits
    provenance: test
  - source: >-
      macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts#failOverdueRuns
      passes over a run whose worker holds it, another host kind’s, and acts only in a tenant context’s
      absence
    provenance: test
dependency_evidence:
  provenance: test
  source: 'macroservice-libraries:packages/workflow-actions/src/tests/integration/worker.integration.spec.ts'
  reviewed:
    - Suite introduction
    - Fixture setup
    - Client substitutions
    - Assertions and cleanup
---
# worker

## Verification Boundary

This database and service suite exercises worker. Its registration records the executable definition; no run result is asserted.

## What This Suite Proves

The suite contains executable checks, but no detailed scenario binding is verified in this pass.

## What It Does Not Prove

In-process execution does not establish deployed infrastructure or a real provider response. Several bindings can supply different parts of a detailed scenario; no single-file completeness is implied.

## Real Dependencies and Test Doubles

The suite definition identifies its database fixtures and replaced clients, hooks, clocks or executors. Integration runs use the prepared database; lifecycle runs exercise the in-process route or adapter path.

## Must Not Be Doubled

The database constraints, transactions and service behavior claimed by an integration binding must execute. Replaced external seams cannot establish live provider or infrastructure behavior.