worker.ts 701 B

1234567891011121314
  1. /**
  2. * Single-statement worker entry that boots `runWorkerSession` on real `parentPort`. Logic remains in
  3. * the session module for in-process MessageChannel coverage; importing this entry on the main thread
  4. * exercises `requireParentPort`'s failure path.
  5. * @module @deepseek-ai/dsh-workflow-worker-thread/worker
  6. */
  7. import { parentPort, workerData } from 'node:worker_threads'
  8. import { requireParentPort, runWorkerSession } from './session.ts'
  9. import type { WorkerInit } from './types.ts'
  10. // workerData is `any` at the node:worker_threads boundary; the engine is the
  11. // only spawner and always provides a WorkerInit.
  12. void runWorkerSession(requireParentPort(parentPort), workerData as WorkerInit)