completeTaskRunByRunId,

failTaskRunByRunId,

startTaskRunByRunId,

} from "../../tasks/task-executor.js";

} from "../../tasks/detached-task-runtime.js";

import type { DeliveryContext } from "../../utils/delivery-context.js";

import {

AcpRuntimeError,

import { scopedHeartbeatWakeOptions } from "../routing/session-key.js";

import { normalizeAssistantPhase } from "../shared/chat-message-content.js";

import { normalizeOptionalString } from "../shared/string-coerce.js";

import { recordTaskRunProgressByRunId } from "../tasks/task-executor.js";

import { recordTaskRunProgressByRunId } from "../tasks/detached-task-runtime.js";

import type { DeliveryContext } from "../utils/delivery-context.types.js";

const DEFAULT_STREAM_FLUSH_MS = 2_500;

areHeartbeatsEnabled: hoisted.areHeartbeatsEnabledMock,

}));

vi.mock("../tasks/task-executor.js", () => ({

vi.mock("../tasks/detached-task-runtime.js", () => ({

createRunningTaskRun: hoisted.createRunningTaskRunMock,

}));

normalizeOptionalLowercaseString,

normalizeOptionalString,

} from "../shared/string-coerce.js";

import { createRunningTaskRun } from "../tasks/task-executor.js";

import { createRunningTaskRun } from "../tasks/detached-task-runtime.js";

import {

deliveryContextFromSession,

formatConversationTarget,

},

}));

vi.mock("../tasks/task-executor.js", () => ({

vi.mock("../tasks/detached-task-runtime.js", () => ({

completeTaskRunByRunId: vi.fn(),

createRunningTaskRun: vi.fn(),

failTaskRunByRunId: vi.fn(),

recordTaskRunProgressByRunId,

setDetachedTaskDeliveryStatusByRunId,

startTaskRunByRunId,

} from "../../tasks/task-executor.js";

} from "../../tasks/detached-task-runtime.js";

import {

cancelTaskByIdForOwner,

findTaskByRunIdForOwner,

cleanupBrowserSessionsForLifecycleEnd: vi.fn(async () => {}),

}));

vi.mock("../tasks/task-executor.js", () => ({

vi.mock("../tasks/detached-task-runtime.js", () => ({

completeTaskRunByRunId: taskExecutorMocks.completeTaskRunByRunId,

failTaskRunByRunId: taskExecutorMocks.failTaskRunByRunId,

setDetachedTaskDeliveryStatusByRunId: taskExecutorMocks.setDetachedTaskDeliveryStatusByRunId,

completeTaskRunByRunId,

failTaskRunByRunId,

setDetachedTaskDeliveryStatusByRunId,

} from "../tasks/task-executor.js";

} from "../tasks/detached-task-runtime.js";

import { normalizeDeliveryContext } from "../utils/delivery-context.js";

import {

captureSubagentCompletionReply,

import { callGateway } from "../gateway/call.js";

import { createSubsystemLogger } from "../logging/subsystem.js";

import { getGlobalHookRunner } from "../plugins/hook-runner-global.js";

import { createRunningTaskRun } from "../tasks/task-executor.js";

import { createRunningTaskRun } from "../tasks/detached-task-runtime.js";

import { type DeliveryContext, normalizeDeliveryContext } from "../utils/delivery-context.js";

import { waitForAgentRun } from "./run-wait.js";

import type { ensureRuntimePluginsLoaded as ensureRuntimePluginsLoadedFn } from "./runtime-plugins.js";

createRunningTaskRun,

failTaskRunByRunId,

recordTaskRunProgressByRunId,

} from "../../tasks/task-executor.js";

} from "../../tasks/detached-task-runtime.js";

import { sendMessage } from "../../tasks/task-registry-delivery-runtime.js";

import type { DeliveryContext } from "../../utils/delivery-context.js";

import { INTERNAL_MESSAGE_CHANNEL } from "../../utils/message-channel.js";