Method runJob

src/runtime/adapters/scheduler.ts:216–332

* Execute a scheduled job: call agent.handleMessage and push results. * Returns { text, notifyFailed } so callers can produce accurate status.

(
    jobConfig: ScheduledJobConfig,
  )

  // -------------------------------------------------------------------------

  /**
   * Execute a scheduled job: call agent.handleMessage and push results.
   * Returns { text, notifyFailed } so callers can produce accurate status.
   */
  private async runJob(
    jobConfig: ScheduledJobConfig,
  ): Promise<{ text: string; notifyFailed: boolean }> {
    const channelId = `scheduler-${jobConfig.id}`;
    const job = this.jobs.get(jobConfig.id);

    if (job?.running) {
      console.warn(
        `[Scheduler] Job "${jobConfig.name}" is already running, skipping this trigger`,
      );
      return { text: "", notifyFailed: false };
    }

    if (job) job.running = true;

    console.log(`[Scheduler] Running job "${jobConfig.name}"`);

    let fullText = "";
    let agentFailed = false;
    let loggedFirstTextDelta = false;
    let sawAgentStart = false;
    let sawAgentEnd = false;
    const pendingFiles: Array<{ filePath: string; caption?: string }> = [];

    const onEvent = (event: AgentEvent) => {
      if (event.type === "agent_start") {
        sawAgentStart = true;
      } else if (event.type === "agent_end") {
        sawAgentEnd = true;
      }

      if (event.type === "agent_start" || event.type === "agent_end") {
        console.log(
          `[Scheduler] Forwarding ${event.type} for ${channelId} (ipc=${this.ipcBroadcaster ? "yes" : "no"})`,
        );
      } else if (event.type === "text_delta" && !loggedFirstTextDelta) {
        loggedFirstTextDelta = true;
        console.log(
          `[Scheduler] Forwarding first text_delta for ${channelId} (${event.delta.length} chars, ipc=${this.ipcBroadcaster ? "yes" : "no"})`,
        );
      }

      this.ipcBroadcaster?.broadcastAgentEvent(channelId, event);
      if (event.type === "text_delta") fullText += event.delta;
      if (event.type === "file_output") {
        pendingFiles.push({
          filePath: event.filePath,
          caption: event.caption,
        });
      }
    };

    try {
      await this.clearJobContext(channelId);