Function buildActionPayload

worker/src/temporal/input-resolver.ts:185–248

(
  action: WorkflowAction,
  results: Map<string, unknown>,
  options: {
    componentMetadata?: ComponentMetadataSnapshot;
  } = {},
)

}

export function buildActionPayload(
  action: WorkflowAction,
  results: Map<string, unknown>,
  options: {
    componentMetadata?: ComponentMetadataSnapshot;
  } = {},
): {
  inputs: Record<string, unknown>;
  params: Record<string, unknown>;
  warnings: InputWarning[];
  manualOverrides: ManualOverride[];
} {
  const params = { ...(action.params ?? {}) } as Record<string, unknown>;
  const inputs = { ...(action.inputOverrides ?? {}) } as Record<string, unknown>;
  const warnings: InputWarning[] = [];
  const manualOverrides: ManualOverride[] = [];

  const inputMetadata = new Map(
    (options.componentMetadata?.inputs ?? []).map((port) => [port.id, port]),
  );

  for (const [targetKey, mapping] of Object.entries(action.inputMappings ?? {})) {
    const portMetadata = inputMetadata.get(targetKey);
    const preferManual = portMetadata?.valuePriority === 'manual-first';
    const manualProvided =
      preferManual && Object.prototype.hasOwnProperty.call(inputs, targetKey)
        ? inputs[targetKey] !== undefined
        : false;

    if (manualProvided) {
      manualOverrides.push({ target: targetKey });
      continue;
    }

    const sourceOutput = results.get(mapping.sourceRef);
    const resolved = resolveInputValue(sourceOutput, mapping.sourceHandle);

    if (resolved !== undefined) {
      if (portMetadata?.connectionType) {
        const coercion = coerceValueForConnectionType(portMetadata.connectionType, resolved);
        if (coercion.ok) {
          inputs[targetKey] = coercion.value;
        } else {
          warnings.push({
            target: targetKey,
            sourceRef: mapping.sourceRef,
            sourceHandle: mapping.sourceHandle,
          });
          continue;
        }
      } else {
        inputs[targetKey] = resolved;
      }
    } else {
      warnings.push({
        target: targetKey,
        sourceRef: mapping.sourceRef,
        sourceHandle: mapping.sourceHandle,