Interface IDataPipelineTriggerService

Namespace

FoundationaLLM.DataPipelineEngine.Interfaces

Assembly

FoundationaLLM.DataPipelineEngine.dll

Defines the interface for the Data Pipeline Trigger service.

public interface IDataPipelineTriggerService

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Methods

TriggerDataPipeline(string, DataPipelineRun, DataPipelineDefinitionSnapshot, UnifiedUserIdentity)

Creates a new data pipeline run.

Task<DataPipelineRun?> TriggerDataPipeline(string instanceId, DataPipelineRun dataPipelineRun, DataPipelineDefinitionSnapshot dataPipelineSnapshot, UnifiedUserIdentity userIdentity)

Parameters

instanceId string

The FoundationaLLM instance identifier.

dataPipelineRun DataPipelineRun

The data pipeline run to create.

dataPipelineSnapshot DataPipelineDefinitionSnapshot

The snapshot of the definition of the data pipeline at the time the run was triggered.

userIdentity UnifiedUserIdentity

The identity of the user running the operation.

Returns

Task<DataPipelineRun>

The newly created data pipeline run.