Class DataPipelineTriggerService

Namespace

FoundationaLLM.DataPipelineEngine.Services

Assembly

FoundationaLLM.DataPipelineEngine.dll

Provides capabilities for triggering data pipeline runs.

public class DataPipelineTriggerService : DataPipelineBackgroundService, IHostedService, IDisposable, IResourceProviderClient, IDataPipelineTriggerService

Inheritance

object

BackgroundService

DataPipelineBackgroundService

DataPipelineTriggerService

Implements

IHostedService

IDisposable

IResourceProviderClient

IDataPipelineTriggerService

Inherited Members

DataPipelineBackgroundService._serviceProvider

DataPipelineBackgroundService._logger

DataPipelineBackgroundService._initializationTask

DataPipelineBackgroundService._pluginService

DataPipelineBackgroundService._dataPipelineResourceProvider

DataPipelineBackgroundService.ResourceProviders

DataPipelineBackgroundService.InitializeAsyncInternal(CancellationToken)

DataPipelineBackgroundService.ExecuteAsync(CancellationToken)

BackgroundService.Dispose()

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.ExecuteTask

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

DataPipelineTriggerService(IResourceValidatorFactory, IServiceProvider, ILogger<DataPipelineTriggerService>)

Provides capabilities for triggering data pipeline runs.

public DataPipelineTriggerService(IResourceValidatorFactory resourceValidatorFactory, IServiceProvider serviceProvider, ILogger<DataPipelineTriggerService> logger)

Parameters

resourceValidatorFactory IResourceValidatorFactory

The factory used to create resource validators.

serviceProvider IServiceProvider

The service collection provided by the dependency injection container.

logger ILogger<DataPipelineTriggerService>

The logger used for logging.

Properties

ServiceName

protected override string ServiceName { get; }

Property Value

string

Methods

ExecuteAsyncInternal(CancellationToken)

Executes the background service's main logic.

protected override Task ExecuteAsyncInternal(CancellationToken stoppingToken)

Parameters

stoppingToken CancellationToken

The cancellation token used to signal a request to stop the service.

Returns

Task

SetResourceProviders(IEnumerable<IResourceProviderService>)

Implements additional resource provider initialization.

protected override void SetResourceProviders(IEnumerable<IResourceProviderService> resourceProviders)

Parameters

resourceProviders IEnumerable<IResourceProviderService>

The collection of resource providers available in the main dependency injection container.

TriggerDataPipeline(string, DataPipelineRun, DataPipelineDefinitionSnapshot, UnifiedUserIdentity)

Creates a new data pipeline run.

public 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.