Table of Contents

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 IPipelineExecutionService

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

StopAsync(CancellationToken)

Triggered when the application host is performing a graceful shutdown.

public override Task StopAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Indicates that the shutdown process should no longer be graceful.

Returns

Task

A Task that represents the asynchronous Stop operation.