feat(workflow-executor): add RunStore implementations (InMemoryStore + DatabaseStore)

[matthv]

Summary

• InMemoryStore — Simple Map-based RunStore implementation for unit tests
• DatabaseStore — Sequelize-based RunStore with auto-migration via umzug
  • Single table workflow_step_executions with JSON data column for flexible schema
  • Indexed by run_id for fast lookups, unique constraint on (run_id, step_index)
  • Dialect-agnostic upsert (delete + insert) — works across SQLite, Postgres, MySQL, etc.
  • Migration applied automatically at startup via store.migrate() (idempotent)
  • No manual migrations needed at the client — DB adapts on its own

Test plan

• InMemoryStore: empty get, save/retrieve, multi-step, upsert, run isolation (6 tests)
• DatabaseStore (SQLite): empty get, save/retrieve, multi-step, ordering, upsert, run isolation, nested JSON, idempotent migration (8 tests)
• Lint clean
• 13 tests pass

fixes PRD-221

🤖 Generated with Claude Code

Note

Add InMemoryStore and DatabaseStore implementations of RunStore

• Adds InMemoryStore (in-memory-store.ts) using nested Maps with upsert-by-stepIndex and sorted retrieval, and DatabaseStore (database-store.ts) backed by Sequelize with Umzug-managed migrations and a transactional delete-then-insert upsert.
• Adds buildInMemoryRunStore and buildDatabaseRunStore factory functions that initialize the store before returning it; buildDatabaseRunStore closes the Sequelize connection if initialization fails.
• Extends the RunStore interface with init(): Promise<void> and close(): Promise<void> lifecycle methods; Runner.start() now calls runStore.init() and Runner.stop() calls runStore.close() via Promise.allSettled.
• Risk: Runner.stop() now uses Promise.allSettled for shutdown, so a failure in aiClient.closeConnections() no longer prevents runStore.close() from being called (and vice versa) — previously the first rejection would short-circuit the other.

Changes since #1506 opened

• Replaced custom DatabaseConfig interface with native sequelize Options interface for buildDatabaseRunStore function [cab9e38]
• Modified RunStore interface to accept optional Logger parameter in init and close methods, updated Runner to pass its logger instance to runStore.init and runStore.close, and enhanced DatabaseStore implementation to log migration failures during init and database connection closure failures during close using the provided logger [75510d5]
• Removed duplicate init and close mock definitions from mock RunStore implementations in test files [75510d5]
• Removed userConfirmed property from makeContext helper function calls across all step executor test files [153b647]
• Added userConfirmed boolean field to pendingData objects in test setups and assertions [bb168ff]
• Changed no-pending-data test cases to expect 'awaiting-input' status instead of error outcomes [bb168ff]

^{Macroscope summarized a36fce9.}

[linear]

PRD-221 Implémenter le RunStore avec Sequelize

[qltysh]

Coverage Impact

Unable to calculate total coverage change because base branch coverage was not found.

Modified Files with Diff Coverage (5)

Rating	File	% Diff	Uncovered Line #s
	packages/workflow-executor/src/runner.ts	100.0%
	packages/workflow-executor/src/stores/in-memory-store.ts	100.0%
	packages/workflow-executor/src/stores/build-run-store.ts	33.3%	10-21, 25-28
	packages/workflow-executor/src/index.ts	100.0%
	packages/workflow-executor/src/stores/database-store.ts	84.6%	69, 81-84, 121
	Total	75.0%

🤖 Increase coverage with AI coding...

In the `feature/prd-221-implementer-le-runstore-avec-sequelize` branch, add test coverage for this new code:

- `packages/workflow-executor/src/stores/build-run-store.ts` -- Lines 10-21 and 25-28
- `packages/workflow-executor/src/stores/database-store.ts` -- Lines 69, 81-84, and 121

🚦 See full report on Qlty Cloud »

🛟 Help

• Diff Coverage: Coverage for added or modified lines of code (excludes deleted files). Learn more.

• Total Coverage: Coverage for the whole repository, calculated as the sum of all File Coverage. Learn more.

• File Coverage: Covered Lines divided by Covered Lines plus Missed Lines. (Excludes non-executable lines including blank lines and comments.)

  • Indirect Changes: Changes to File Coverage for files that were not modified in this PR. Learn more.

[matthv]

Both Macroscope comments addressed in 29f7cba:

1. Transaction on upsert — saveStepExecution now wraps DELETE + INSERT in this.sequelize.transaction() to make the operation atomic.
2. Sort order in InMemoryStore — getStepExecutions now sorts by stepIndex to match the DatabaseStore contract (ORDER BY step_index ASC). Added a dedicated ordering test.

14 tests pass, lint clean.

[Scra3]

👀