Function resolveInputValue

worker/src/temporal/input-resolver.ts:145–173

(sourceOutput: unknown, sourceHandle: string)

}

export function resolveInputValue(sourceOutput: unknown, sourceHandle: string): unknown {
  if (sourceOutput === null || sourceOutput === undefined) {
    return undefined;
  }

  if (sourceHandle === '__self__') {
    return sourceOutput;
  }

  if (typeof sourceOutput === 'object') {
    const record = sourceOutput as Record<string, unknown>;

    // If it's a spilled marker, we return the marker itself along with the sourceHandle
    // The activity will then be responsible for fetching the full data
    // and extracting the specific handle.
    if (isSpilledDataMarker(sourceOutput)) {
      return {
        ...sourceOutput,
        __spilled_handle__: sourceHandle,
      };
    }

    if (Object.prototype.hasOwnProperty.call(record, sourceHandle)) {
      return record[sourceHandle];
    }
  }

  return undefined;
}

interface ComponentInputMetadata {
  id: string;