DeepSeek/deepseek-harness
1
0
Fork 0
mirror of https://github.com/deepseek-ai/deepseek-harness synced 2026-08-15 21:04:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master' into fix/preset-host-plane-task-registry

Browse Source
This commit is contained in:
Yichen Jiang
2026-08-10 16:53:03 +08:00
parent be7bf24169 09c3622697
commit 8ae1a9d6a8
459 changed files with 1342 additions and 1329 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/tasks/tasks-local/src/index.ts
View File

@@ -142,8 +142,8 @@ export class LocalTaskService extends TaskService {
void hooks.done.then(
(outcome) => { this.settle(task, outcome) },
(error: unknown) => {
// Contain a producer contract violation so cleanup and waiters cannot hang.
this.selfCtx.logger.warn(`tasks: task ${task.id} 'done' rejected (producer contract violation): ${String(error)}`)
// Contain a producer contract violation (`done` rejected) so cleanup and waiters cannot hang.
this.selfCtx.logger.warn(`tasks: task ${task.id} producer done promise rejected (producer contract violation): ${String(error)}`)
this.settle(task, { status: 'failed', detail: String(error) })
},
)

2
packages/tasks/tasks-local/tests/tasks.spec.ts
View File

@@ -264,7 +264,7 @@ describe('LocalTaskService reads and settlement', () => {
expect(warn).toHaveBeenCalledWith(expect.stringContaining('async listener boom'))
})
it('contains a rejecting done as a failed outcome (producer contract violation)', async () => {
it("contains rejection from the producer's done promise as a failed outcome (producer contract violation)", async () => {
const ctx = await harness()
const warn = vi.spyOn(ctx.logger, 'warn').mockImplementation(() => {})
const p = producer()