diff --git a/server/services/schedule_loader.js b/server/services/schedule_loader.js index 6795c91..a49670d 100644 --- a/server/services/schedule_loader.js +++ b/server/services/schedule_loader.js @@ -4,6 +4,7 @@ import { execute_action_and_record } from './task_executor.js'; import { get_flow_runner } from './flows/flow_registry.js'; const cron_jobs = []; +const running_task_name_set = new Set(); async function run_cron_task(task) { if (!task || !task.type) { @@ -30,13 +31,23 @@ async function run_cron_task(task) { export async function start_all_cron_tasks() { for (const task of cron_task_list) { - // const job = cron.schedule(task.cron_expression, async () => { - - await run_cron_task(task); - - // }); + const task_name = task && task.name ? String(task.name) : 'cron_task'; + const job = cron.schedule(task.cron_expression, async () => { + if (running_task_name_set.has(task_name)) { + // eslint-disable-next-line no-console + console.log('[cron] skip (already running)', { name: task_name }); + return; + } - // cron_jobs.push(job); + running_task_name_set.add(task_name); + try { + await run_cron_task(task); + } finally { + running_task_name_set.delete(task_name); + } + }); + + cron_jobs.push(job); } } @@ -45,4 +56,5 @@ export function stop_all_cron_tasks() { job.stop(); } cron_jobs.length = 0; + running_task_name_set.clear(); }