SetPipelineExecutionResultNode
Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline.Nodes.Loads
Pipeline node that captures the current data context value at the configured path and stores it as the pipeline execution result (OutputData). The result is persisted on the PipelineExecution entity when the execution completes. Only pipelines that include this node will have OutputData stored — this avoids unintended storage of large results from high-frequency pipelines.
public class SetPipelineExecutionResultNode : IPipelineNode
Inheritance Object → SetPipelineExecutionResultNode
Implements IPipelineNode
Fields
ExecutionResultPropertyKey
Key used to store the execution result in IEtlContext.Properties.
public static string ExecutionResultPropertyKey;
Constructors
SetPipelineExecutionResultNode(NodeDelegate, IEtlContext)
Pipeline node that captures the current data context value at the configured path and stores it as the pipeline execution result (OutputData). The result is persisted on the PipelineExecution entity when the execution completes. Only pipelines that include this node will have OutputData stored — this avoids unintended storage of large results from high-frequency pipelines.
public SetPipelineExecutionResultNode(NodeDelegate next, IEtlContext etlContext)
Parameters
next NodeDelegate
etlContext IEtlContext
Methods
ProcessObjectAsync(IDataContext, INodeContext)
public Task ProcessObjectAsync(IDataContext dataContext, INodeContext nodeContext)
Parameters
dataContext IDataContext
nodeContext INodeContext