Function addChartsToQueue

server/crons/updateCharts.js:30–110

(charts, queue)

}

async function addChartsToQueue(charts, queue) {
  const addJobPromises = charts.map(async (chart) => {
    const chartToUpdate = chart.dataValues ? chart.dataValues : chart;
    const traceContext = await startRun({
      triggerType: "chart_auto",
      entityType: "chart",
      status: "queued",
      teamId: chart.Project?.team_id || null,
      projectId: chartToUpdate.project_id,
      chartId: chartToUpdate.id,
      queueName: queue.name,
      summary: {
        autoUpdateSeconds: chartToUpdate.autoUpdate || null,
      },
    });
    const queueEvent = await startEvent(traceContext, "queue_enqueued", {
      chartId: chartToUpdate.id,
      projectId: chartToUpdate.project_id,
      queueName: queue.name,
    });
    const candidateJobId = buildJobId("chart", chartToUpdate.id);

    try {
      const job = await queue.add("updateChart", {
        chart: chartToUpdate,
        traceContext,
      }, {
        jobId: candidateJobId,
        deduplication: {
          id: `chart_${chartToUpdate.id}`,
        },
      });

      const returnedJobId = `${job.id}`;
      const deduplicated = returnedJobId !== candidateJobId;
      traceContext.jobId = returnedJobId;
      traceContext.queueName = queue.name;

      await finishEvent(traceContext, queueEvent, deduplicated ? "deduplicated" : "success", {
        chartId: chartToUpdate.id,
        candidateJobId,
        returnedJobId,
        deduplicated,
      });
      await updateRunContext(traceContext, {
        jobId: returnedJobId,
        queueName: queue.name,
        status: deduplicated ? "deduplicated" : "queued",
      });

      if (deduplicated) {
        await completeRun(traceContext, {
          status: "deduplicated",
          summary: {
            chartId: chartToUpdate.id,
            deduplicated: true,
            candidateJobId,
            returnedJobId,