fix: align worker PWD with task cwd

Author: javazys

CHANGELOG.md

@@ -2,6 +2,14 @@
 
 All notable user-facing changes are recorded here. This project follows semantic versioning while it is in the `0.x` development series.
 
+## [0.1.37] - 2026-07-18
+
+### Fixed
+
+- Gateway-managed OpenCode runs now set `PWD` to the task working directory, preventing OpenCode server errors when PM2's saved `PWD` differs from the task's `cwd`.
+
+[0.1.37]: https://github.com/vbgate/opencode-supertask/compare/v0.1.36...v0.1.37
+
 ## [0.1.36] - 2026-07-18
 
 ### Added

package.json

@@ -1,6 +1,6 @@
 {
     "name": "opencode-supertask",
-    "version": "0.1.36",
+    "version": "0.1.37",
     "description": "AI Agent 任务调度系统 — OpenCode 插件 + CLI + Gateway 常驻进程",
     "type": "module",
     "main": "dist/plugin/supertask.js",

src/worker/index.ts

@@ -291,6 +291,7 @@ export class WorkerEngine {
         const args = ['run', '--agent', task.agent, '--format', 'json'];
         if (model) args.push('-m', model);
         args.push(task.prompt);
+        const cwd = task.cwd || process.cwd();
 
         const child = spawn(process.execPath, [
             this.launcherEntry(),
@@ -299,9 +300,10 @@ export class WorkerEngine {
             this.opencodeBin,
             ...args,
         ], {
-            cwd: task.cwd || process.cwd(),
+            cwd,
             env: {
                 ...process.env,
+                PWD: cwd,
                 [MANAGED_RUN_ENV]: MANAGED_RUN_ENV_VALUE,
             },
             stdio: ['pipe', 'pipe', 'pipe', 'ipc'],
@@ -312,7 +314,7 @@ export class WorkerEngine {
             runId,
             launchIdentity,
             child,
-            commandContext: runCommandContext(this.opencodeBin, args, task.cwd || process.cwd()),
+            commandContext: runCommandContext(this.opencodeBin, args, cwd),
             output: '',
             sessionId: null,
             timeoutTimer: null,

tests/worker-engine.test.ts

@@ -41,7 +41,11 @@ function createFakeOpencode(options: {
     const source = `#!/usr/bin/env bun
 const args = Bun.argv.slice(2);
 await Bun.write(${JSON.stringify(argsFile)}, JSON.stringify(args));
-await Bun.write(${JSON.stringify(envFile)}, JSON.stringify({ managedRun: process.env[${JSON.stringify(MANAGED_RUN_ENV)}] }));
+await Bun.write(${JSON.stringify(envFile)}, JSON.stringify({
+    managedRun: process.env[${JSON.stringify(MANAGED_RUN_ENV)}],
+    pwd: process.env.PWD,
+    cwd: process.cwd(),
+}));
 console.log(JSON.stringify({ sessionID: "ses_worker_test", message: "任务执行完成" }));
 ${options.ignoreSigterm ? "process.on('SIGTERM', () => {});" : ''}
 await Bun.sleep(${options.delayMs ?? 0});
@@ -170,21 +174,28 @@ describe('WorkerEngine', () => {
             model: 'test-model',
             prompt,
             maxRetries: 0,
+            cwd: fake.dir,
         });
         const worker = new WorkerEngine(createConfig(), { opencodeBin: fake.executable });
         workers.push(worker);
 
         worker.start();
         const completed = await waitForStatus(task.id, ['done']);
         const args = JSON.parse(readFileSync(fake.argsFile, 'utf-8')) as string[];
-        const childEnv = JSON.parse(readFileSync(fake.envFile, 'utf-8')) as { managedRun?: string };
+        const childEnv = JSON.parse(readFileSync(fake.envFile, 'utf-8')) as {
+            managedRun?: string;
+            pwd?: string;
+            cwd: string;
+        };
         const runs = await TaskRunService.listByTaskId(task.id);
 
         expect(args).toEqual([
             'run', '--agent', 'test-agent', '--format', 'json',
             '-m', 'test-model', prompt,
         ]);
         expect(childEnv.managedRun).toBe(MANAGED_RUN_ENV_VALUE);
+        expect(childEnv.cwd).toBe(fake.dir);
+        expect(childEnv.pwd).toBe(fake.dir);
         expect(existsSync(marker)).toBe(false);
         expect(completed.resultLog).toContain('任务执行完成');
         expect(runs).toHaveLength(1);