Pine/deepseek-harness
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases 1 Wiki Activity

Stabilize workflow worker coverage wait

Browse Source
This commit is contained in:
Tianyi Cui
2026-07-10 00:55:47 +08:00
parent 9d2cf8ce82
commit 5f7177a0a9
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/workflow/workflow-workerthread/tests/workflow-workerthread.spec.ts
+4 -2
View File
@@ -17,6 +17,8 @@ function fakeParent(): Agent {
/** The vm-context escape hatch, spelled once: real Worker tests use it to make the WORKER misbehave. */ /** The vm-context escape hatch, spelled once: real Worker tests use it to make the WORKER misbehave. */
const ESCAPE = "globalThis.constructor.constructor('return process')()" const ESCAPE = "globalThis.constructor.constructor('return process')()"
/** Linux coverage workers can take longer than Vitest's default waitFor timeout to start executing script. */
const WORKER_CHILD_START_TIMEOUT_MS = 3_000
/** One controllable child run: the test (or auto mode) settles it. */ /** One controllable child run: the test (or auto mode) settles it. */
interface ControlledRun { interface ControlledRun {
@@ -572,7 +574,7 @@ describe('dsh-workflow-workerthread', () => {
`), `),
parent: fakeParent(), parent: fakeParent(),
}) })
await vi.waitFor(() => { expect(starts).toBe(1) }) await vi.waitFor(() => { expect(starts).toBe(1) }, { timeout: WORKER_CHILD_START_TIMEOUT_MS })
handle.cancel('stop now') handle.cancel('stop now')
await vi.waitFor(() => { expect(cancelled).toEqual(['stop now']) }, { timeout: 800 }) await vi.waitFor(() => { expect(cancelled).toEqual(['stop now']) }, { timeout: 800 })
// The wedged worker's own completion loses to the in-flight cancel. // The wedged worker's own completion loses to the in-flight cancel.
@@ -602,7 +604,7 @@ describe('dsh-workflow-workerthread', () => {
`), `),
parent, parent,
}) })
await vi.waitFor(() => { expect(provider.runs.length).toBe(1) }) await vi.waitFor(() => { expect(provider.runs.length).toBe(1) }, { timeout: WORKER_CHILD_START_TIMEOUT_MS })
const before = Date.now() const before = Date.now()
await handle.dispose() await handle.dispose()
// Bounded by the grace (plus the terminate), never by the 1.5s spin. // Bounded by the grace (plus the terminate), never by the 1.5s spin.