Function cleanup_task_

apps/backend/services/task_service.js:357–396

()

 
async function cleanup_task_() {
  //const worker_pids_array = Array.from(worker_pids);  // convert Set to Array
  
  //const pids_for_query = process_sync_worker_pids.join(','); 
  const pids_for_query = get_worker_pids().join(','); // note
  //logger(LOG_LEVEL.INFO, `PIDs: ${process_sync_worker_pids}`);


  let where_pid_clause = '';

  if (pids_for_query.length > 0) {
    where_pid_clause = `AND (PID IS NULL OR PID NOT IN (${pids_for_query}))`;
  } else {
    // where_pid_clause = `AND PID IS NULL`;
    return logger(LOG_LEVEL.ERROR, `cleanup_task pids_for_query is empty.`, memo);
  }

  // set status = UPDATE_STATUS.TERMINATED
  const query = `
    UPDATE TASK
        SET STATUS = -2,
            PID = ${process.pid},
            RETRY = RETRY - 1
      WHERE STATUS IN (0, 1, -3)
        AND FINISH_AT IS NULL
        ${where_pid_clause};
    `;
    // AND (PID IS NULL OR PID NOT IN (${pids_for_query}));
  const memo = operation_memo({});
  try {
    const pool = await pool_promise;
    const result = await pool.request().query(query);
      
    if (result.rowsAffected[0] > 0) {
      logger(LOG_LEVEL.INFO, `cleanup_task clean up ${result.rowsAffected[0]} records.`, memo);
    } 
  } catch (err) {
    logger(LOG_LEVEL.ERROR, `cleanup_task ${err}.`, memo);
  }
}      

/**
 * @brief Update transcription task status and details