Class DataPipelineWorkerService

Namespace

FoundationaLLM.DataPipelineEngine.Services

Assembly

FoundationaLLM.DataPipelineEngine.dll

Provides capabilites for background processing of data pipeline work items.

public class DataPipelineWorkerService : BackgroundService, IHostedService, IDisposable

Inheritance

object

BackgroundService

DataPipelineWorkerService

Implements

IHostedService

IDisposable

Inherited Members

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

DataPipelineWorkerService(IDataPipelineStateService, IEnumerable<IResourceProviderService>, IMessageQueueService<DataPipelineRunWorkItemMessage>, IOptions<DataPipelineWorkerServiceSettings>, IServiceProvider, ILogger<DataPipelineWorkerService>)

Initializes a new instance of the service.

public DataPipelineWorkerService(IDataPipelineStateService stateService, IEnumerable<IResourceProviderService> resourceProviderServices, IMessageQueueService<DataPipelineRunWorkItemMessage> queueService, IOptions<DataPipelineWorkerServiceSettings> options, IServiceProvider serviceProvider, ILogger<DataPipelineWorkerService> logger)

Parameters

stateService IDataPipelineStateService

The Data Pipeline State service providing state management services.

resourceProviderServices IEnumerable<IResourceProviderService>

The FoundationaLLM resource provider services.

queueService IMessageQueueService<DataPipelineRunWorkItemMessage>

The message queue service providing queueing capabilities.

options IOptions<DataPipelineWorkerServiceSettings>

The options with the service settings.

serviceProvider IServiceProvider

The service collection provided by the dependency injection container.

logger ILogger<DataPipelineWorkerService>

The logger used for logging.

Methods

ExecuteAsync(CancellationToken)

This method is called when the IHostedService starts. The implementation should return a task that represents the lifetime of the long running operation(s) being performed.

protected override Task ExecuteAsync(CancellationToken stoppingToken)

Parameters

stoppingToken CancellationToken

Triggered when StopAsync(CancellationToken) is called.

Returns

Task

A Task that represents the long running operations.

Remarks

See Worker Services in .NET for implementation guidelines.