mirror of
https://github.com/n8n-io/n8n.git
synced 2026-10-17 21:49:36 +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. |
||
|---|---|---|
| .. | ||
| @n8n | ||
| cli | ||
| core | ||
| extensions/insights | ||
| frontend | ||
| modules | ||
| node-dev | ||
| nodes-base | ||
| quality | ||
| workflow | ||