mirror of
https://github.com/n8n-io/n8n.git
synced 2026-10-18 05:59:42 +02:00
75b94ccad5
Start the reads of a queue consumer when its message is published, so the reads run while the message waits in the serial queue. - step:settled: the step, the execution, the failed-step probe and the successor summaries. The reads start after the settlement commits. - step:ready: the predecessor rows for the step inputs. The claim and the execution status read after the claim stay on the critical path. A consumer that finds no prefetch does the same reads itself. Ordering change: the settled handler can see an execution status that is older by one queue wait. If a cancel lands in that window, one more step can be planned. The ready handler cancels that step after its claim. createSteps still checks for failed steps under the execution lock. Planning reads still run after the settlement of the step commits, so the last predecessor of a successor to settle sees the others settled. No durability change. |
||
|---|---|---|
| .. | ||
| docs/adr | ||
| src | ||
| .dockerignore | ||
| .gitignore | ||
| AGENTS.md | ||
| eslint.config.mjs | ||
| oxlint.config.mts | ||
| package.json | ||
| README.md | ||
| tsconfig.build.json | ||
| tsconfig.json | ||
| vitest.config.ts | ||
| vitest.integration.config.ts | ||
@n8n/engine
n8n workflow execution engine (v2).
See the Engine v2 project for context. Public API and core interfaces are still being defined; the package is currently a scaffold and is not yet wired into n8n.
Dependencies
Be careful adding dependencies here. This package should not have runtime dependencies on other n8n components, only interfaces. If there is some functionality that should be shared, it should be factored into a common library.