Function buildWorkflowResultContextMessage

src/common/utils/workflowRunMessages.ts:92–132

(input: {
  rawCommand: string;
  name: string;
  runId: string;
  status: string;
  result: unknown;
  run: WorkflowRunRecord | null;
})

}

export function buildWorkflowResultContextMessage(input: {
  rawCommand: string;
  name: string;
  runId: string;
  status: string;
  result: unknown;
  run: WorkflowRunRecord | null;
}): string {
  assert(
    input.rawCommand.trim().length > 0,
    "buildWorkflowResultContextMessage: rawCommand required"
  );
  assert(input.name.length > 0, "buildWorkflowResultContextMessage: workflow name required");
  assert(input.runId.length > 0, "buildWorkflowResultContextMessage: runId required");

  const resultValue = getWorkflowResultValue(input.result, input.run);
  const reportMarkdown = getWorkflowResultField(resultValue, "reportMarkdown");
  const structuredOutput = getWorkflowResultField(resultValue, "structuredOutput");
  const workflowError = getWorkflowError({
    run: input.run,
    status: input.status,
    resultValue,
  });
  const payload = {
    workflow: {
      name: input.name,
      runId: input.runId,
      status: input.status,
    },
    ...(typeof reportMarkdown === "string" ? { reportMarkdown } : {}),
    ...(structuredOutput !== undefined ? { structuredOutput } : {}),
    ...(resultValue != null ? { result: resultValue } : {}),
    ...(workflowError ? { error: workflowError } : {}),
  };

  return [
    "The workflow below has finished. Continue the agent turn for the original request using this workflow result. Do not merely restate the raw payload; synthesize the next answer or action from it.",
    `Original workflow command: ${input.rawCommand}`,
    `<${WORKFLOW_RESULT_XML_TAG}>\n${stringifyWorkflowResultPayload(payload)}\n</${WORKFLOW_RESULT_XML_TAG}>`,
  ].join("\n\n");
}

export interface WorkflowRunCardInput {
  scriptPath?: string;