Interface IDataPipelineRunnerService

Namespace

FoundationaLLM.DataPipelineEngine.Interfaces

Assembly

FoundationaLLM.DataPipelineEngine.dll

Defines the interface for the data pipeline runner service.

public interface IDataPipelineRunnerService

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Properties

CurrentRunners

Gets the current data pipeline runners that are processing runs.

Dictionary<string, DataPipelineRunner> CurrentRunners { get; }

Property Value

Dictionary<string, DataPipelineRunner>

Methods

CanStartRun(DataPipelineRun)

Inidicates whether the specified data pipeline run can be started.

Task<bool> CanStartRun(DataPipelineRun dataPipelineRun)

Parameters

dataPipelineRun DataPipelineRun

The data pipeline run to start.

Returns

Task<bool>

true if the specified data pipeline run can be started, false otherwise.

StartRun(DataPipelineRun, List<DataPipelineContentItem>, DataPipelineDefinition, UnifiedUserIdentity)

Starts a data pipeline run.

Task<DataPipelineRun> StartRun(DataPipelineRun dataPipelineRun, List<DataPipelineContentItem> contentItems, DataPipelineDefinition dataPipelineDefinition, UnifiedUserIdentity userIdentity)

Parameters

dataPipelineRun DataPipelineRun

The data pipeline run to start.

contentItems List<DataPipelineContentItem>

The list of content items to process.

dataPipelineDefinition DataPipelineDefinition

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 started data pipeline run.