fix(tasks): restore owner-key task scope

vincentkoc · vincentkoc · commit 80ed55332d77 · 2026-04-01T03:53:12.000+09:00
diff --git a/src/acp/control-plane/manager.core.ts b/src/acp/control-plane/manager.core.ts
@@ -1887,7 +1887,8 @@ export class AcpSessionManager {
       createRunningTaskRun({
         runtime: "acp",
         sourceId: context.runId,
-        requesterSessionKey: context.requesterSessionKey,
+        ownerKey: context.requesterSessionKey,
+        scopeKind: "session",
         requesterOrigin: context.requesterOrigin,
         childSessionKey: context.childSessionKey,
         runId: context.runId,
diff --git a/src/cron/service/ops.ts b/src/cron/service/ops.ts
@@ -400,7 +400,8 @@ function tryCreateManualTaskRun(params: {
     createRunningTaskRun({
       runtime: "cron",
       sourceId: params.job.id,
-      requesterSessionKey: "",
+      ownerKey: "",
+      scopeKind: "system",
       childSessionKey: params.job.sessionKey,
       agentId: params.job.agentId,
       runId,
diff --git a/src/cron/service/timer.ts b/src/cron/service/timer.ts
@@ -138,7 +138,8 @@ function tryCreateCronTaskRun(params: {
     createRunningTaskRun({
       runtime: "cron",
       sourceId: params.job.id,
-      requesterSessionKey: "",
+      ownerKey: "",
+      scopeKind: "system",
       childSessionKey: params.job.sessionKey,
       agentId: params.job.agentId,
       runId,
diff --git a/src/tasks/task-executor.test.ts b/src/tasks/task-executor.test.ts
@@ -67,7 +67,8 @@ describe("task-executor", () => {
     await withTaskExecutorStateDir(async () => {
       const created = createQueuedTaskRun({
         runtime: "acp",
-        requesterSessionKey: "agent:main:main",
+        ownerKey: "agent:main:main",
+        scopeKind: "session",
         childSessionKey: "agent:codex:acp:child",
         runId: "run-executor-queued",
         task: "Investigate issue",
@@ -103,7 +104,8 @@ describe("task-executor", () => {
     await withTaskExecutorStateDir(async () => {
       const created = createRunningTaskRun({
         runtime: "subagent",
-        requesterSessionKey: "agent:main:main",
+        ownerKey: "agent:main:main",
+        scopeKind: "session",
         childSessionKey: "agent:codex:subagent:child",
         runId: "run-executor-fail",
         task: "Write summary",
@@ -143,7 +145,8 @@ describe("task-executor", () => {
     await withTaskExecutorStateDir(async () => {
       const created = createRunningTaskRun({
         runtime: "acp",
-        requesterSessionKey: "agent:main:main",
+        ownerKey: "agent:main:main",
+        scopeKind: "session",
         requesterOrigin: {
           channel: "telegram",
           to: "telegram:123",
@@ -179,7 +182,8 @@ describe("task-executor", () => {
 
       const child = createRunningTaskRun({
         runtime: "acp",
-        requesterSessionKey: "agent:main:main",
+        ownerKey: "agent:main:main",
+        scopeKind: "session",
         childSessionKey: "agent:codex:acp:child",
         runId: "run-linear-cancel",
         task: "Inspect a PR",
@@ -217,7 +221,8 @@ describe("task-executor", () => {
 
       const child = createRunningTaskRun({
         runtime: "subagent",
-        requesterSessionKey: "agent:main:main",
+        ownerKey: "agent:main:main",
+        scopeKind: "session",
         childSessionKey: "agent:codex:subagent:child",
         runId: "run-subagent-cancel",
         task: "Inspect a PR",
@@ -249,15 +254,17 @@ describe("task-executor", () => {
     await withTaskExecutorStateDir(async () => {
       const victim = createRunningTaskRun({
         runtime: "acp",
-        requesterSessionKey: "agent:victim:main",
+        ownerKey: "agent:victim:main",
+        scopeKind: "session",
         childSessionKey: "agent:victim:acp:child",
         runId: "run-shared-executor-scope",
         task: "Victim ACP task",
         deliveryStatus: "pending",
       });
       const attacker = createRunningTaskRun({
         runtime: "cli",
-        requesterSessionKey: "agent:attacker:main",
+        ownerKey: "agent:attacker:main",
+        scopeKind: "session",
         childSessionKey: "agent:attacker:main",
         runId: "run-shared-executor-scope",
         task: "Attacker CLI task",
diff --git a/src/tasks/task-registry.test.ts b/src/tasks/task-registry.test.ts
diff --git a/src/tasks/task-registry.ts b/src/tasks/task-registry.ts
