e1483ab80a
move worker startup logic from server.ts to runtime.ts for better modularity add worker-loop-policy.ts for loop control abstraction delete legacy unit tests under tests/unit/ related to compute worker and control-plane add vitest config and test directories for compute-core and compute-worker add vitest workflow for CI update package.json scripts for new test commands and add vitest as dev dependency BREAKING CHANGE: worker entrypoint is now compute/worker/src/runtime.ts instead of server.ts; legacy Playwright-based unit tests for compute worker are removed in favor of Vitest
18 lines
906 B
TypeScript
18 lines
906 B
TypeScript
import { describe, expect, test } from 'vitest';
|
|
import { buildQueueWaitTiming, decideRetryAction } from '../../src/worker-loop-policy';
|
|
|
|
describe('worker loop policy', () => {
|
|
test('returns queue wait timing with non-negative clamped duration', () => {
|
|
expect(buildQueueWaitTiming(1000, 1300)).toEqual({ queueWaitMs: 300 });
|
|
expect(buildQueueWaitTiming(1500, 1300)).toEqual({ queueWaitMs: 0 });
|
|
});
|
|
|
|
test('retry policy: layout jobs can retry until max attempts', () => {
|
|
expect(decideRetryAction({ kind: 'pdf_layout', deliveryCount: 1, pdfAttempts: 3 })).toBe('nak_retry');
|
|
expect(decideRetryAction({ kind: 'pdf_layout', deliveryCount: 3, pdfAttempts: 3 })).toBe('term_fail');
|
|
});
|
|
|
|
test('retry policy: whisper jobs terminate immediately by default', () => {
|
|
expect(decideRetryAction({ kind: 'whisper_align', deliveryCount: 1, pdfAttempts: 10 })).toBe('term_fail');
|
|
});
|
|
});
|