shazhou/united-workforce
8
0
Fork 0
Code Issues 8 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

fix: fix 7 failing tests (OCAS_DIR → OCAS_HOME + restore workflow destructure) #53

Closed
xiaoju wants to merge 1 commits from chore/fix-failing-tests into main
pull from: chore/fix-failing-tests
merge into: shazhou:main
Conversation 3 Commits 1 Files Changed 3
+5 -5
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/cli/src/__tests__/current-role.test.ts
+1 -1
View File
@@ -324,7 +324,7 @@ describe("currentRole field", () => {
try { try {
const wf = join(tmpDir, "test-current-role.yaml"); const wf = join(tmpDir, "test-current-role.yaml");
await writeFile(wf, SIMPLE_WORKFLOW_YAML, "utf8"); 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; const tid = thread as ThreadId;
await createMarker(storageRoot, { await createMarker(storageRoot, {
packages/cli/src/__tests__/store-unified-threads.test.ts
+1 -1
View File
@@ -15,7 +15,7 @@ import {
async function makeUwfStore(storageRoot: string) { async function makeUwfStore(storageRoot: string) {
const casDir = join(storageRoot, "cas"); const casDir = join(storageRoot, "cas");
await mkdir(casDir, { recursive: true }); await mkdir(casDir, { recursive: true });
process.env.OCAS_DIR = casDir; process.env.OCAS_HOME = casDir;
return createUwfStore(storageRoot); return createUwfStore(storageRoot);
} }
packages/cli/src/__tests__/thread-resume.test.ts
+3 -3
View File
@@ -491,7 +491,7 @@ describe("uwf thread resume - completed threads", () => {
cwd: tmpDir, cwd: tmpDir,
}); });
process.env.OCAS_DIR = casDir; process.env.OCAS_HOME = casDir;
const workerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" }); const workerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" });
const reviewerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" }); const reviewerOutputHash = await store.cas.put(outputSchemaHash, { $status: "_" });
@@ -654,7 +654,7 @@ echo '${adapterJson}'
cwd: tmpDir, cwd: tmpDir,
}); });
process.env.OCAS_DIR = casDir; process.env.OCAS_HOME = casDir;
await seedThreads(tmpDir, { await seedThreads(tmpDir, {
[THREAD_ID]: { [THREAD_ID]: {
head: startHash, head: startHash,
@@ -702,7 +702,7 @@ echo '${adapterJson}'
cwd: tmpDir, cwd: tmpDir,
}); });
process.env.OCAS_DIR = casDir; process.env.OCAS_HOME = casDir;
await seedThreads(tmpDir, { [THREAD_ID]: startHash }); await seedThreads(tmpDir, { [THREAD_ID]: startHash });
const result = runUwf(["thread", "resume", THREAD_ID], casDir); const result = runUwf(["thread", "resume", THREAD_ID], casDir);