@@ -0,0 +1 @@
+A run that ended early on `needs-human`, `already-claimed`, `tip-unchanged` or `open-pr` no longer reads as a failed step: the run log ends with `⏹ 提前结束 · <reason>` and still quotes the Bot's reply, instead of saying the node failed and stopped there ([#1577](https://github.com/ThinkFlowLab/FlyBot/issues/1577)).
@@ -89,6 +89,17 @@ function botReply(workflow, nodeId, text) {
   return { kind: 'bot', botId: nodeId, step: stepLabel(workflow, nodeId), text }
 }
 
+// A step can end the run early without failing (#1537, #1538): the row names why it
+// stopped instead of the failure copy, and a Bot reply is still quoted when there is one.
+function earlyEndLines(workflow, event) {
+  if (event.earlyEnd == null) return null
+  const reply = quoted(event.text)
+  return [
+    ...(reply ? [botReply(workflow, event.nodeId, reply)] : []),
+    frame('system', '⏹ Ended early · {reason}', { reason: event.earlyEnd }, `⏹ 提前结束 · ${event.earlyEnd}`),
+  ]
+}
+
 // A live run quotes the Bot when event.text is set; otherwise a frame fills in.
 function liveLines(workflow, task, event) {
   const label = summarizeTask(task)
@@ -100,6 +111,8 @@ function liveLines(workflow, task, event) {
     return [frame('system', 'Started · {task} · {nodes}', { task: label, nodes }, `开始 · ${label} · ${nodes}`, { tone: 'accent' })]
   }
   if (event.type === 'fail') {
+    const ended = earlyEndLines(workflow, event)
+    if (ended) return ended
     if (event.recovered === true && event.started.length > 0) {
       const target = names(workflow, event.started)
       return [
@@ -147,6 +160,8 @@ export function linesFor(workflow, task, event) {
     return [frame('system', 'Task {task} entered the workflow; {nodes} claimed it', { task: label, nodes }, `任务 ${label} 已进入 Workflow，${nodes} 认领`, { tone: 'accent' })]
   }
   if (event.type === 'fail') {
+    const ended = earlyEndLines(workflow, event)
+    if (ended) return ended
     if (event.recovered === true && event.started.length > 0) {
       const target = names(workflow, event.started)
       return [
 
@@ -0,0 +1,103 @@
+// A run that ended early (needs-human / already-claimed / tip-unchanged / open-pr)
+// is not a failure: the log says why it stopped, not that it stopped on the node.
+import assert from 'node:assert/strict'
+import { test } from 'node:test'
+import { linesFor } from '../src/narrate.js'
+import { normalizeGraph } from '../src/graph.js'
+import { createWorkflowService } from '../src/service.js'
+
+const roster = [
+  { id: 'bot-claim', name: 'Claim', role: 'Claim', remote: false },
+  { id: 'bot-verify', name: 'Verify', role: 'Verify', remote: false },
+  { id: 'bot-land', name: 'Land', role: 'Land', remote: false },
+]
+
+function graph() {
+  return normalizeGraph({
+    id: 'claim-verify-land',
+    name: 'Claim Verify Land',
+    nodes: [
+      { id: 'claim', name: 'Claim', role: 'Claim', outputs: [{ name: 'claimed', type: 'text' }] },
+      { id: 'verify', name: 'Verify', role: 'Verify', inputs: [{ name: 'claimed', type: 'text' }], outputs: [{ name: 'status', type: 'text' }] },
+      { id: 'land', name: 'Land', role: 'Land', inputs: [{ name: 'status', type: 'text' }] },
+    ],
+    edges: [
+      { from: 'claim', to: 'verify' },
+      { from: 'verify', to: 'land' },
+    ],
+  })
+}
+
+const task = { id: '#1577', title: 'Early end' }
+
+function failEvent(extra = {}) {
+  return { type: 'fail', nodeId: 'verify', started: [], joined: false, finished: true, layerSize: 0, live: true, text: '', recovered: false, ...extra }
+}
+
+test('live fail with earlyEnd and no reply says early end, never failure', () => {
+  const lines = linesFor(graph(), task, failEvent({ earlyEnd: 'tip-unchanged' }))
+  assert.equal(lines.some(line => String(line.text).includes('失败')), false, JSON.stringify(lines))
+  const end = lines.find(line => String(line.text).includes('提前结束'))
+  assert.ok(end, JSON.stringify(lines))
+  assert.equal(end.kind, 'system')
+  assert.match(end.text, /tip-unchanged/)
+  assert.equal(end.key, '⏹ Ended early · {reason}', 'the shell translates the key, the stored text is the fallback')
+  assert.deepEqual(end.params, { reason: 'tip-unchanged' })
+  assert.notEqual(end.tone, 'bad')
+})
+
+test('live fail with earlyEnd keeps the Bot reply and adds the early-end line', () => {
+  const lines = linesFor(graph(), task, failEvent({ earlyEnd: 'open-pr', text: 'PR #1533 is already open for this issue.' }))
+  const bot = lines.find(line => line.kind === 'bot')
+  assert.equal(bot?.text, 'PR #1533 is already open for this issue.')
+  assert.equal(lines.some(line => String(line.text).includes('失败')), false, JSON.stringify(lines))
+  assert.ok(lines.some(line => String(line.text).includes('提前结束') && String(line.text).includes('open-pr')))
+})
+
+test('complete with earlyEnd still ends on the ok finish line and adds no early-end line', () => {
+  const lines = linesFor(graph(), task, {
+    type: 'complete', nodeId: 'land', started: [], joined: false, finished: true, layerSize: 1, live: true, text: '', earlyEnd: 'already-claimed',
+  })
+  assert.ok(lines.some(line => String(line.text).startsWith('✓ 完成')))
+  assert.equal(lines.some(line => String(line.text).includes('提前结束')), false, JSON.stringify(lines))
+})
+
+test('a plain live failure still says the run stopped on this node', () => {
+  const lines = linesFor(graph(), task, failEvent())
+  assert.ok(lines.some(line => String(line.text).includes('停在本节点')), JSON.stringify(lines))
+  assert.equal(lines.some(line => String(line.text).includes('提前结束')), false)
+})
+
+test('a recovered live failure still says it recovered', () => {
+  const lines = linesFor(graph(), task, failEvent({ recovered: true, started: ['claim'] }))
+  assert.ok(lines.some(line => String(line.text).includes('失败恢复')))
+  assert.equal(lines.some(line => String(line.text).includes('提前结束')), false)
+})
+
+test('non-live fail with earlyEnd says early end, never failure', () => {
+  const lines = linesFor(graph(), task, { ...failEvent({ earlyEnd: 'needs-human' }), live: false })
+  assert.equal(lines.some(line => String(line.text).includes('失败')), false, JSON.stringify(lines))
+  assert.ok(lines.some(line => String(line.text).includes('提前结束') && String(line.text).includes('needs-human')))
+})
+
+test('service: a Verify reply that marks tip-unchanged narrates the early end', () => {
+  const svc = createWorkflowService({ persist: false, now: () => 1_700_000_000_000, bots: () => roster })
+  const base = graph()
+  const created = svc.create({ name: base.name, nodes: base.nodes, edges: base.edges })
+  const workflowId = created.workflows.find(workflow => workflow.name === base.name).id
+  svc.assign({ workflowId, taskId: '#1577', title: 'Early end' })
+  svc.advance({ workflowId, nodeId: 'claim', outcome: 'done', outputs: { claimed: 'ok' }, text: 'Claimed.' })
+
+  const result = svc.advance({
+    workflowId,
+    nodeId: 'verify',
+    outcome: 'failed',
+    text: 'Suite green at this tip; tip unchanged from the previous pass.',
+  })
+  const workflow = result.workflows.find(item => item.id === workflowId)
+  const texts = workflow.messages.map(line => String(line.text))
+  assert.equal(workflow.run.status, 'done')
+  assert.equal(workflow.run.earlyEnd, 'tip-unchanged')
+  assert.equal(texts.some(text => text.includes('失败')), false, texts.join(' | '))
+  assert.ok(texts.some(text => text.includes('提前结束') && text.includes('tip-unchanged')), texts.join(' | '))
+})
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	+A run that ended early on `needs-human`, `already-claimed`, `tip-unchanged` or `open-pr` no longer reads as a failed step: the run log ends with `⏹ 提前结束 · <reason>` and still quotes the Bot's reply, instead of saying the node failed and stopped there ([#1577](https://github.com/ThinkFlowLab/FlyBot/issues/1577)).