Class AgentRecordProcessor

Runs an Agent for each record, mapping the record into the agent's input data.

Implements

IRecordProcessor

Index

Constructors

Methods

ProcessRecord buildData

Constructors

constructor

new AgentRecordProcessor(
agentID: string,
inputMapping?: unknown,
): AgentRecordProcessor
Parameters
- agentID: string
  ID of the Agent to run (must be top-level + ExposeAsAction).
- OptionalinputMapping: unknown
  Optional mapping config resolved against { record, recordId, entityId } to build the agent's data. When omitted, the whole record is passed as data.
Returns AgentRecordProcessor
- Defined in RecordSetProcessor/engine/src/processors/AgentRecordProcessor.ts:26

Methods

ProcessRecord

ProcessRecord(
record: RecordRef,
context: RecordProcessorContext,
): Promise<RecordResult>
Processes one record.
Parameters
- record: RecordRef
  The record to process.
- context: RecordProcessorContext
  The per-record execution context.
Returns Promise<RecordResult>
The record's outcome (Succeeded / Failed / Skipped) plus any payload / trace links.
Implementation of IRecordProcessor.ProcessRecord
- Defined in RecordSetProcessor/engine/src/processors/AgentRecordProcessor.ts:37

`Static`buildData

buildData(inputMapping: unknown, record: RecordRef): Record<string, unknown>
Builds the agent data payload from the record + optional input mapping.
Parameters
- inputMapping: unknown
- record: RecordRef
Returns Record<string, unknown>
- Defined in RecordSetProcessor/engine/src/processors/AgentRecordProcessor.ts:29