diff --git a/packages/cli/src/__tests__/current-role.test.ts b/packages/cli/src/__tests__/current-role.test.ts index 310a1aa..c234ed7 100644 --- a/packages/cli/src/__tests__/current-role.test.ts +++ b/packages/cli/src/__tests__/current-role.test.ts @@ -324,7 +324,7 @@ describe("currentRole field", () => { try { const wf = join(tmpDir, "test-current-role.yaml"); await writeFile(wf, SIMPLE_WORKFLOW_YAML, "utf8"); - const { thread } = await cmdThreadStart(storageRoot, wf, "test", tmpDir); + const { thread, workflow } = await cmdThreadStart(storageRoot, wf, "test", tmpDir); const tid = thread as ThreadId; await createMarker(storageRoot, { diff --git a/packages/cli/src/__tests__/store-unified-threads.test.ts b/packages/cli/src/__tests__/store-unified-threads.test.ts index 247db5d..be1647a 100644 --- a/packages/cli/src/__tests__/store-unified-threads.test.ts +++ b/packages/cli/src/__tests__/store-unified-threads.test.ts @@ -15,7 +15,7 @@ import { async function makeUwfStore(storageRoot: string) { const casDir = join(storageRoot, "cas"); await mkdir(casDir, { recursive: true }); - process.env.OCAS_DIR = casDir; + process.env.OCAS_HOME = casDir; return createUwfStore(storageRoot); } diff --git a/packages/cli/src/__tests__/thread-resume.test.ts b/packages/cli/src/__tests__/thread-resume.test.ts index 3b8aa9e..d53e4b6 100644 --- a/packages/cli/src/__tests__/thread-resume.test.ts +++ b/packages/cli/src/__tests__/thread-resume.test.ts @@ -491,7 +491,7 @@ describe("uwf thread resume - completed threads", () => { cwd: tmpDir, }); - process.env.OCAS_DIR = casDir; + process.env.OCAS_HOME = casDir; const workerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" }); const reviewerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" }); @@ -654,7 +654,7 @@ echo '${adapterJson}' cwd: tmpDir, }); - process.env.OCAS_DIR = casDir; + process.env.OCAS_HOME = casDir; await seedThreads(tmpDir, { [THREAD_ID]: { head: startHash, @@ -702,7 +702,7 @@ echo '${adapterJson}' cwd: tmpDir, }); - process.env.OCAS_DIR = casDir; + process.env.OCAS_HOME = casDir; await seedThreads(tmpDir, { [THREAD_ID]: startHash }); const result = runUwf(["thread", "resume", THREAD_ID], casDir);