diff --git a/services/orchestrator/executor-adapters.test.mjs b/services/orchestrator/executor-adapters.test.mjs index 25ad14c..6bbc782 100644 --- a/services/orchestrator/executor-adapters.test.mjs +++ b/services/orchestrator/executor-adapters.test.mjs @@ -57,6 +57,7 @@ test('Goosed adapter uses the current session API, streams bounded metadata and ]); } if (url.endsWith('/reply')) return Response.json({ ok: true }); + if (url.endsWith('/status')) return Response.json({ ok: true }); throw new Error(`Unexpected URL: ${url}`); }, }); @@ -83,6 +84,7 @@ test('Goosed adapter uses the current session API, streams bounded metadata and ], ); assert.equal(JSON.stringify(emitted).includes('not-projected'), false); + assert.deepEqual(await adapter.health(), { ok: true, status: 200 }); }); test('Goosed adapter rejects remote targets unless explicitly allowed', () => { diff --git a/services/orchestrator/executor-worker-runtime.test.mjs b/services/orchestrator/executor-worker-runtime.test.mjs index be399af..f462462 100644 --- a/services/orchestrator/executor-worker-runtime.test.mjs +++ b/services/orchestrator/executor-worker-runtime.test.mjs @@ -85,6 +85,7 @@ test('worker runtime claims, executes, emits progress and completes through leas client.calls.map((call) => call[0]), ['claim', 'start', 'progress', 'complete'], ); + assert.deepEqual(client.calls[0][1].adapterHealth, { goosed: { ok: true } }); assert.equal(client.calls.at(-1)[2].leaseToken, 'lease-1'); assert.deepEqual(worker.status().activeJobs, []); });