Method failAgentTaskForHardTimeout

src/node/services/taskService.ts:5146–5187

(
    taskId: string,
    options: { workflowRunId: string; stepId: string; inputHash: string; reason: string }
  )

  }

  async failAgentTaskForHardTimeout(
    taskId: string,
    options: { workflowRunId: string; stepId: string; inputHash: string; reason: string }
  ): Promise<void> {
    assert(taskId.length > 0, "failAgentTaskForHardTimeout: taskId must be non-empty");
    assert(options.reason.length > 0, "failAgentTaskForHardTimeout: reason must be non-empty");

    await this.workspaceEventLocks.withLock(taskId, async () => {
      const cfg = this.config.loadConfigOrDefault();
      const entry = findWorkspaceEntry(cfg, taskId);
      if (!entry?.workspace.parentWorkspaceId) {
        return;
      }
      if (hasCompletedAgentReport(entry.workspace) || this.completedReportsByTaskId.has(taskId)) {
        return;
      }
      try {
        const clearQueueResult = this.workspaceService.clearQueue(taskId);
        if (!clearQueueResult.success) {
          log.debug("failAgentTaskForHardTimeout: clearQueue failed", {
            taskId,
            error: clearQueueResult.error,
          });
        }
      } catch (error: unknown) {
        log.debug("failAgentTaskForHardTimeout: clearQueue threw", { taskId, error });
      }
      try {
        await this.aiService.stopStream(taskId, {
          abandonPartial: true,
          abortReason: "system",
        });
      } catch (error: unknown) {
        log.debug("failAgentTaskForHardTimeout: stopStream threw", { taskId, error });
      }
      await this.terminateAllDescendantAgentTasks(taskId, { workflowRunId: options.workflowRunId });
      await this.failAgentTaskTerminally(taskId, entry, {
        errorType: "workflow_agent_timeout",
        errorMessage: options.reason,
      });
    });
  }

  async waitForAgentReport(
    taskId: string,