Class DataPipelineService

Namespace

FoundationaLLM.DataPipelineEngine.Services

Assembly

FoundationaLLM.DataPipelineEngine.dll

Provides services for managing data pipelines.

public class DataPipelineService : IDataPipelineService

Inheritance

object

DataPipelineService

Implements

IDataPipelineService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Constructors

DataPipelineService(IEnumerable<IResourceProviderService>, DataPipelineServiceSettings, ILogger<DataPipelineService>)

Provides services for managing data pipelines.

public DataPipelineService(IEnumerable<IResourceProviderService> resourceProviders, DataPipelineServiceSettings settings, ILogger<DataPipelineService> logger)

Parameters

resourceProviders IEnumerable<IResourceProviderService>

The FoundationaLLM resource providers.

settings DataPipelineServiceSettings

The settings for the service.

logger ILogger<DataPipelineService>

The logger used for logging.

Methods

CreateDataPipelineRun(string, DataPipelineRun, UnifiedUserIdentity)

Creates a new data pipeline run.

public Task<DataPipelineRun> CreateDataPipelineRun(string instanceId, DataPipelineRun dataPipelineRun, UnifiedUserIdentity userIdentity)

Parameters

instanceId string

The FoundationaLLM instance identifier.

dataPipelineRun DataPipelineRun

The object with the properties of the new data pipeline run.

userIdentity UnifiedUserIdentity

Returns

Task<DataPipelineRun>

The newly created data pipeline run.

GetDataPipelineRun(string, string, string, UnifiedUserIdentity)

Retrieves a data pipeline run by its name.

public Task<DataPipelineRun> GetDataPipelineRun(string instanceId, string dataPipelineName, string runId, UnifiedUserIdentity userIdentity)

Parameters

instanceId string

The FoundationaLLM instance identifier.

dataPipelineName string

The name of the data pipeline.

runId string

The identifier of the data pipeline run.

userIdentity UnifiedUserIdentity

Returns

Task<DataPipelineRun>

The data pipeline run identified by the provided identifier.

GetDataPipelineRuns(string, DataPipelineRunFilter, UnifiedUserIdentity)

Retrieves a list of data pipeline runs filtered by the provided filter criteria.

public Task<List<DataPipelineRun>> GetDataPipelineRuns(string instanceId, DataPipelineRunFilter dataPipelineRunFilter, UnifiedUserIdentity userIdentity)

Parameters

instanceId string

The FoundationaLLM instance identifier.

dataPipelineRunFilter DataPipelineRunFilter

The definition of the filter criteria.

userIdentity UnifiedUserIdentity

The identity of the user running the operation.

Returns

Task<List<DataPipelineRun>>

The requested list of data pipeline run objects.