Function startRun

server/modules/updateAudit.js:322–399

(payload = {}, parentTraceContext = null)

}

async function startRun(payload = {}, parentTraceContext = null) {
  const baseContext = cloneTraceContext(parentTraceContext);
  const traceId = payload.traceId || createTraceId();
  const rootTraceId = payload.rootTraceId || baseContext.rootTraceId || traceId;
  const startedAt = payload.startedAt || new Date();

  const context = {
    ...baseContext,
    traceId,
    rootTraceId,
    parentRunId: payload.parentRunId !== undefined ? payload.parentRunId : baseContext.runId,
    triggerType: payload.triggerType || baseContext.triggerType || "unknown",
    entityType: payload.entityType || baseContext.entityType || "unknown",
    teamId: payload.teamId !== undefined ? payload.teamId : baseContext.teamId,
    projectId: payload.projectId !== undefined ? payload.projectId : baseContext.projectId,
    chartId: payload.chartId !== undefined ? payload.chartId : baseContext.chartId,
    datasetId: payload.datasetId !== undefined ? payload.datasetId : baseContext.datasetId,
    dataRequestId: payload.dataRequestId !== undefined
      ? payload.dataRequestId
      : baseContext.dataRequestId,
    connectionId: payload.connectionId !== undefined
      ? payload.connectionId
      : baseContext.connectionId,
    queueName: payload.queueName !== undefined ? payload.queueName : baseContext.queueName,
    jobId: payload.jobId !== undefined ? payload.jobId : baseContext.jobId,
    nextSequence: 1,
    startedAt,
  };

  const createValues = {
    traceId: context.traceId,
    rootTraceId: context.rootTraceId,
    parentRunId: context.parentRunId,
    triggerType: context.triggerType,
    entityType: context.entityType,
    teamId: context.teamId,
    projectId: context.projectId,
    chartId: context.chartId,
    datasetId: context.datasetId,
    dataRequestId: context.dataRequestId,
    connectionId: context.connectionId,
    queueName: context.queueName,
    jobId: context.jobId,
    status: payload.status || "running",
    startedAt,
    summary: sanitizePayload(payload.summary),
  };

  try {
    if (db.UpdateRun) {
      const run = await db.UpdateRun.create(createValues);
      context.runId = run.id;
    }
  } catch (error) {
    emitAuditInternalError("[updateAudit] failed to create run", error);
  }

  emitStructuredAuditLog("run_started", {