Function dispatchHeadlessCronCommand

src/cli/print.ts:2845–2876

(params: {
      basePrompt: string
      sourceId: string
      sourceLabel: string
      logSuffix: string
      onSuccess: (command: QueuedCommand) => void | Promise<void>
    })

    // dispatch. onSuccess receives the claimed QueuedCommand and decides
    // whether to enqueue it (normal path) or mark the run failed (agent path).
    const dispatchHeadlessCronCommand = (params: {
      basePrompt: string
      sourceId: string
      sourceLabel: string
      logSuffix: string
      onSuccess: (command: QueuedCommand) => void | Promise<void>
    }): void => {
      if (inputClosed) return
      void (async () => {
        const command = await createAutonomyQueuedPromptIfNoActiveSource({
          basePrompt: params.basePrompt,
          trigger: 'scheduled-task',
          currentDir: cwd(),
          sourceId: params.sourceId,
          sourceLabel: params.sourceLabel,
          workload: WORKLOAD_CRON,
          shouldCreate: () => !inputClosed,
        })
        if (!command) return
        if (inputClosed) {
          await cancelQueuedAutonomyCommands({ commands: [command] })
          return
        }
        await params.onSuccess(command)
      })().catch(error => {
        logError(error)
        logForDebugging(
          `[ScheduledTasks] failed to enqueue headless task${params.logSuffix}: ${error}`,
          { level: 'error' },
        )
      })
    }

    const enqueueAndRun = (command: QueuedCommand): void => {
      enqueue({