Repository navigation

Add firefly/orchestration: sagas, TCC and durable workflows - #15

Merged

ancongui merged 59 commits into

mainfrom

feat/orchestration

Oct 13, 2026

Merged

Add firefly/orchestration: sagas, TCC and durable workflows#15
ancongui merged 59 commits into
mainfrom
feat/orchestration

Commits on Oct 13, 2026
- feat(orchestration): register the firefly/orchestration package in the library, deptrac and the installer
  Andres Contreras
  committed
  4cff364
- feat(orchestration): execution enums, topology layering, conditions and the exception family
  Andres Contreras
  committed
  eb3620b
- feat(orchestration): the execution context and its JSON-safe checkpoint state
  Andres Contreras
  committed
  aa45388
- fix(orchestration): refuse cyclic and over-deep step results instead of exhausting memory mid-checkpoint
  Andres Contreras
  committed
  1c93cbc
- fix(orchestration): budget the checkpoint envelope in the depth guard and refuse non-finite floats and invalid UTF-8
  Andres Contreras
  committed
  96959a2
- feat(orchestration): compiled argument injection, a resilience-backed step invoker and lifecycle callbacks
  Andres Contreras
  committed
  90505e2
- feat(orchestration): lifecycle hooks, a metrics seam, EDA lifecycle events and the trigger gateway
  Andres Contreras
  committed
  259c462
- fix(orchestration): stamp the EDA x-correlation-id and partition_key headers on lifecycle events
  Andres Contreras
  committed
  1136e9e
- feat(orchestration): the execution persistence port with memory and cache providers, and a re-entrant execution lock
  Andres Contreras
  committed
  d2a80ad
- feat(orchestration): settings and their reference, execution reports, the dead-letter queue and back-pressure admission
  Andres Contreras
  committed
  0f7cfa1
- feat(orchestration): saga attributes, validated definitions, the registry, the builder DSL and saga results
  Andres Contreras
  committed
  8f4d3cf
- feat(orchestration): the five saga compensation policies and the compensation error handlers
  Andres Contreras
  committed
  50cbe93
- fix(orchestration): run compensation handler retries through the saga circuit breaker
  Andres Contreras
  committed
  fd17998
- fix(orchestration): fall back to the default compensation breaker only when the saga has none configured
  Andres Contreras
  committed
  3f672ee
- fix(orchestration): throw a CompensationException when the circuit-breaker policy stops the compensation sweep
  Andres Contreras
  committed
  0e7257b
- feat(orchestration): the saga engine — layered execution, deadlines, idempotency, compensation, dead letters, resume
  Andres Contreras
  committed
  45770aa
- fix(orchestration): refuse to start a saga under a correlation id that already exists
  Andres Contreras
  committed
  b3bcfad
- feat(orchestration): saga composition with data flow and compensation of the members that completed
  Andres Contreras
  committed
  e02ce4b
- fix(orchestration): report the composition members a rollback could not undo and tolerate optional members that cannot start
  Andres Contreras
  committed
  8212410
- feat(orchestration): TCC transactions with ordered participants, per-phase retries, phase checkpoints and composition
  Andres Contreras
  committed
  21e636e
- fix(orchestration): checkpoint a required TCC failure under CANCEL so a resume never retries it or reports CONFIRMED
  Andres Contreras
  committed
  3576fbf
- fix(orchestration): honor the TCC composition compensation policy and resume an interrupted cancel on request as one
  Andres Contreras
  committed
  b0a6ccd
- fix(orchestration): cancel TCC participants whose try timed out or was interrupted, with a null try result
  Andres Contreras
  committed
  d2177ef
- feat(orchestration): workflow attributes, validated definitions with waits, children and queries, and the builder DSL
  Andres Contreras
  committed
  2e8dd1e
- fix(orchestration): validate every workflow step's wait at definition time and refuse a manifest wait without a known kind
  Andres Contreras
  committed
  c61a49e
- feat(orchestration): durable workflows with signals, timers, children, continue-as-new and queries, plus dead-letter retry
  Andres Contreras
  committed
  5b48e36
- fix(orchestration): keep a cancelled or compensated parent from being re-driven by its children, and keep the tick going past an execution it cannot drive
  Andres Contreras
  committed
  29b9af8
- fix(orchestration): re-check a waiting parent's child on every drive, keep the continue-as-new origin out of children, fail a parent whose child cannot start, and refuse a taken workflow correlatio…
  Andres Contreras
  committed
  80860fc
- fix(orchestration): record a child's origin run so a child that continued as new still wakes its parent, keep the report and deadline on a search-attribute upsert, back off due workflows the tick c…
  Andres Contreras
  committed
  1301d88
- feat(orchestration): portable database persistence and dead-letter store, proven on PostgreSQL, MySQL, MariaDB and SQLite
  Andres Contreras
  committed
  a45d362
- fix(orchestration): rewrite search attributes by exact key and upsert so concurrent saves cannot gap-lock deadlock on MySQL and MariaDB, and retry a top-level save on a deadlock
  Andres Contreras
  committed
  f0a2357
- feat(orchestration): scan sagas, TCCs and workflows into a compiled manifest that firefly:cache emits
  Andres Contreras
  committed
  a80a6fb
- feat(orchestration): auto-configure the engines, register and validate definitions at boot, and start executions from EDA triggers
  Andres Contreras
  committed
  4b077b4
- fix(orchestration): derive a trigger execution's correlation id from the event id and carry the envelope headers, so a redelivered event is acknowledged instead of starting the definition again
  Andres Contreras
  committed
  d6b13dd
- feat(orchestration): recovery that resumes or compensates killed executions, the scheduled tick and sweep, and scheduled orchestrations
  Andres Contreras
  committed
  8a596f6
- fix(orchestration): finish an interrupted workflow compensation on recovery instead of driving the workflow forward
  Andres Contreras
  committed
  8cd8445
- fix(orchestration): re-check a stale execution under its lock before recovery acts, so a run that finished or checkpointed while the sweep waited is skipped instead of undone or driven twice
  Andres Contreras
  committed
  eee42a9
- fix(orchestration): keep a timer that came due between its wait check and the checkpoint in wakeAt, so the tick still wakes that waiting workflow
  Andres Contreras
  committed
  3e164ee
- feat(orchestration): an orchestration actuator endpoint and health component, and commands to list, show, signal, tick and retry
  Andres Contreras
  committed
  b87a153
- feat(orchestration): an opt-in REST surface to start, inspect, signal and retry executions
  Andres Contreras
  committed
  15879d3
- feat(observability): meter and span adapters for sagas, TCC and workflows
  Andres Contreras
  committed
  5389fe6
- docs(orchestration): the orchestration guide, its links, the observability meters and the changelog
  Andres Contreras
  committed
  9308f45
- docs(orchestration): stop claiming SQL Server is proven until its integration tests run in CI
  Andres Contreras
  committed
  224f02a
- test(orchestration): run ASYNC workflows through a real Laravel queue in the capstone and on every database
  Andres Contreras
  committed
  b6792ef
- test(orchestration): cover the #[CompensationStep] workflow form in the scanner, the capstone and on every database
  Andres Contreras
  committed
  ba9eef3
- test(samples): register the firefly:eda:consume provider in the lumen Postgres outbox round-trip harness
  Andres Contreras
  committed
  236bbf6
- fix(orchestration): end a saga whose compensation stopped part-way COMPENSATION_FAILED, dead-letter it and name the steps it left uncompensated
  Andres Contreras
  committed
  0ff0dd4
- fix(orchestration): park a due workflow the tick fails to drive max-resume-attempts times FAILED and dead-letter it, and let database faults escape the tick
  Andres Contreras
  committed
  b9490a1
- fix(orchestration): log a tick failure by exception class, execution and correlation id, and keep the error message at debug level
  Andres Contreras
  committed
  f4a7684
- fix(orchestration): count nested drives and settlements of one workflow by depth, so a nested call no longer clears the outer call's mark
  Andres Contreras
  committed
  5591c6d
- fix(orchestration): replay the child completions a failed cancel or compensation held back, so the parent does not stay WAITING on a child it already cancelled
  Andres Contreras
  committed
  cc89c78
- Merge remote-tracking branch 'origin/main' into feat/orchestration
  Andres Contreras
  committed
  4ed7299
- test(orchestration): read integration DSNs through IntegrationDsn and run every lane of the CI matrix
  Andres Contreras
  committed
  5ad50e3
- fix(orchestration): write search attributes by exact primary key, so a save on SQL Server no longer waits on another execution's open checkpoint
  Andres Contreras
  committed
  24be842
- docs(orchestration): state that SQL Server is proven by the CI integration lane, and add orchestration to the database support matrix
  Andres Contreras
  committed
  a5394ed
- docs(cli): list the six firefly:orchestration commands and recount the guides
  Andres Contreras
  committed
  de0739c
- test(testing): open every SQL Server integration connection unpooled, so no test inherits another's session settings
  Andres Contreras
  committed
  44a6e45
- test(data): say what the deadlock test's parent session saw when the exactly-one-loser check fails
  Andres Contreras
  committed
  4e0b17d
- test(integration): put SQL Server's lock wait back after each test that shortens it, since the runner's driver manager pools sessions
  Andres Contreras
  committed
  a8bc39f

Commits

Commits on Oct 13, 2026