26.246. Interface IWorkerStreamHandler
Namespace: ArmoniK.Core.Common.Stream.Worker
Assembly: ArmoniK.Core.Common.dll
Defines the interface for handling communication with worker processes.
[PublicAPI]
public interface IWorkerStreamHandler : IInitializable, IHealthCheckProvider, IDisposable
26.246.1. Implements
IInitializable, IHealthCheckProvider, IDisposable
26.246.2. Methods
26.246.2.1. StartTaskProcessing(TaskData, string, string, Configuration, CancellationToken)
Sends a task to a worker for processing and waits for its completion.
Task<Output> StartTaskProcessing(TaskData taskData, string token, string dataFolder, Configuration configuration, CancellationToken cancellationToken)
26.246.2.1.1. Parameters
taskData TaskData
The task data containing all information needed to process the task.
token string
Authentication token for the worker.
dataFolder string
The path to the folder where task data can be stored.
configuration Configuration
The configuration to be sent to the worker
cancellationToken CancellationToken
Token to cancel the task processing.
26.246.2.1.2. Returns
The output of the task processing, including status and any error information.