Hacktoberfest 2026:维护者为十月标记出来的 issue,仍然开放、适合新手。 浏览 Hacktoberfest issue

ai-harness: recovery runs a turn without the user message when the turn never started

已关闭
#1,795 0 条评论 0 个 reaction 已指派 1 人 在 GitHub 查看

维护者通常 1 天内回复

@tombeckenham 已经在做这个了。

开始于 2026年10月15日。

  • #1755 来自 @AlemTuzlak —— 已合并

评估

这个 Issue 还没有评估数据。

描述

waiting-on: maintainer
TanStack AI version

@tanstack/ai-harness on the feat/harness-core branch (not released yet).

Framework/Library version

Node 24.8.0. No UI framework: the bug is in the durable host.

Describe the bug and the steps to reproduce it

A durable host (stores.log) stores a prompt in the log, then stops before the turn starts (before it writes its run lease). The next host that opens the thread recovers the input and runs the turn. But the transcript has no user message for that input, so the model gets an empty message list.

Expected: the transcript is ['First.', 'One.']. Actual: ['One.'], and the model call has no messages.

Steps:

  1. Open a durable host whose runs.createOrResume never returns, so the turn never starts.
  2. Send prompt('First.') and wait for the receipt.
  3. Stop the host's claim renewal, and wait until the claim expires.
  4. Open the thread on a second host. It recovers the input and calls the model.
  5. Read transcript() on the second host.

Found during the review of #1780. That PR is not the cause: the same test fails on feat/harness-core before #1780.

Your Minimal, Reproducible Example - (Sandbox Highly Recommended)

A test in packages/ai-harness/tests/:

import { expect, it, vi } from 'vitest'
import { memoryLogStore, memoryPersistence } from '@tanstack/ai-persistence'
import { createHarnessHost, defineHarness } from '../src'
import { mockAdapter, text } from './helpers'

it('recovery keeps the user message of a turn that never started', async () => {
  const { runs, metadata, workClaims } = memoryPersistence().stores
  const persistence = {
    stores: { log: memoryLogStore(), runs, metadata, workClaims },
  }
  const { adapter, calls } = mockAdapter([() => text('One.')])
  const harness = defineHarness({ name: 'probe', adapter })
  const owner = await createHarnessHost({
    lease: { ttlMs: 200, renewMs: 50 },
    persistence: {
      stores: {
        ...persistence.stores,
        runs: Object.assign(Object.create(runs), {
          createOrResume: () => new Promise(() => {}),
        }),
      },
    },
  }).open(harness, { threadId: 't1' })
  await owner.prompt('First.').receipt
  ;(owner as unknown as { stopClaimTimer: () => void }).stopClaimTimer()
  await new Promise((resolve) => setTimeout(resolve, 300))

  const next = await createHarnessHost({ persistence }).open(harness, {
    threadId: 't1',
  })
  await vi.waitFor(() => expect(calls).toHaveLength(1), { timeout: 3_000 })
  await new Promise((resolve) => setTimeout(resolve, 200))
  expect((await next.transcript()).map((message) => message.content)).toEqual([
    'First.',
    'One.',
  ])
})
Do you intend to try to help solve this bug with your own PR?

Maybe, I'll investigate and start debugging

Terms & Code of Conduct
  • I agree to follow this project's Code of Conduct
  • I understand that if my bug cannot be reliable reproduced in a debuggable environment, it will probably not be fixed and this issue may even be closed.
主要语言
TypeScript
星标
3.2k
派生
372
平均合并
1 天 14 小时
30 天内合并 PR
241

环境准备

从这里开始

  1. 先读完整个 Issue,再读项目的贡献指南。
  2. 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
  3. Fork 仓库,在一个分支上完成修改。
  4. 提交 Pull Request,并在描述里引用这个 Issue 编号。

TanStack/ai 的其他 Issue

查看 TanStack/ai 的全部 Issue

相似的 Issue

更多 TypeScript Issue

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。