Function startDaemon

src/tasks/background-scheduled-task/daemon.ts:7–46

(message: any)

import { IpcRunCoordinator } from "../../coordinator/ipc-run-coordinator";

export async function startDaemon(message: any): Promise<ScheduledTask> {
    const script = await importTaskModule(message.path);

    // The inline task in the daemon stays silent; the parent process logs from
    // the forwarded events using the user's configured logger.
    const options: TaskOptions = { ...(message.options || {}), logger: noopLogger };

    // The real coordinator lives in the parent; bridge to it over IPC so the
    // daemon coordinates through the same shared backend as every instance.
    if (options.distributed) {
      options.runCoordinator = new IpcRunCoordinator(process);
    }

    const task = new InlineScheduledTask(message.cron, script.task, options);

    task.on('task:started', (context => sendEvent('task:started', context)));

    task.on('task:stopped', (context => sendEvent('task:stopped', context)));

    task.on('task:destroyed', (context => sendEvent('task:destroyed', context)));

    task.on('execution:started', (context => sendEvent('execution:started', context)));

    task.on('execution:finished', (context => sendEvent('execution:finished', context)));

    task.on('execution:failed', (context => sendEvent('execution:failed', context)));

    task.on('execution:missed', (context => sendEvent('execution:missed', context)));

    task.on('execution:overlap', (context => sendEvent('execution:overlap', context)));

    task.on('execution:maxReached', (context => sendEvent('execution:maxReached', context)));

    task.on('execution:skipped', (context => sendEvent('execution:skipped', context)));

    if (process.send) process.send({ event: 'daemon:started' });

    task.start();
    return task;
}

/* Loading the task file is the one step that legitimately fails at runtime
 * (missing file, a runtime that cannot run the file, unsupported TS syntax in