Function logProgress

apps/hash-ai-worker-ts/src/activities/shared/log-progress.ts:58–82

(logs: StepProgressLog[])

export const flushLogs = sendLogSignal.flush;

export const logProgress = (logs: StepProgressLog[]) => {
  if (logs.length === 0) {
    return;
  }

  const { workflowId, runId } = Context.current().info.workflowExecution ?? {};

  if (!workflowId) {
    throw new Error(
      "No workflowId associated with the current workflow execution",
    );
  }

  if (!runId) {
    throw new Error("No runId associated with the current workflow execution");
  }

  const existingLogs = logQueueByRunId.get(runId) ?? [];

  existingLogs.push(...logs);

  logQueueByRunId.set(runId, existingLogs);

  void sendLogSignal({ workflowId, runId });
};