1

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();
 }