Class PipelineWorker
- Namespace
- FoundationaLLM.Vectorization.Services.Pipelines
- Assembly
- FoundationaLLM.Vectorization.Engine.dll
Background worker used to manage vectorization data pipelines.
public class PipelineWorker : BackgroundService, IHostedService, IDisposable
- Inheritance
-
PipelineWorker
- Implements
- Inherited Members
- Extension Methods
Constructors
PipelineWorker(IPipelineExecutionService, ILogger<PipelineWorker>)
Background worker used to manage vectorization data pipelines.
public PipelineWorker(IPipelineExecutionService pipelineExecutionService, ILogger<PipelineWorker> logger)
Parameters
pipelineExecutionService
IPipelineExecutionServiceThe IPipelineExecutionService managing the execution of vectorization data pipelines.
logger
ILogger<PipelineWorker>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
CancellationTokenTriggered when StopAsync(CancellationToken) is called.
Returns
Remarks
See Worker Services in .NET for implementation guidelines.
StopAsync(CancellationToken)
Triggered when the application host is performing a graceful shutdown.
public override Task StopAsync(CancellationToken cancellationToken)
Parameters
cancellationToken
CancellationTokenIndicates that the shutdown process should no longer be graceful.