Table of Contents

Class NullDataPipelineServiceClient

Namespace
FoundationaLLM.DataPipelineEngine.Clients
Assembly
FoundationaLLM.DataPipelineEngine.dll

Implements a no-operation client.

public class NullDataPipelineServiceClient : IDataPipelineServiceClient, IResourceProviderClient
Inheritance
NullDataPipelineServiceClient
Implements
Inherited Members
Extension Methods

Properties

ResourceProviders

Sets the resource providers collection.

public IEnumerable<IResourceProviderService> ResourceProviders { set; }

Property Value

IEnumerable<IResourceProviderService>

Remarks

This property must be exposed by services that cannot be injected with the resource providers. These are background services that both provide and consume services to and from the resource providers.

Methods

CreateDataPipelineRunAsync(string, DataPipelineRun, DataPipelineDefinitionSnapshot, UnifiedUserIdentity)

Creates a new data pipeline run.

public Task<DataPipelineRun?> CreateDataPipelineRunAsync(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

Returns

Task<DataPipelineRun>

The newly created data pipeline run.

GetDataPipelineRunAsync(string, string, string, UnifiedUserIdentity)

Gets a data pipeline run by its identifier.

public Task<DataPipelineRun?> GetDataPipelineRunAsync(string instanceId, string dataPipelineName, string runId, UnifiedUserIdentity userIdentity)

Parameters

instanceId string

The FoundationaLLM instance identifier.

dataPipelineName string

The name of the data pipeline.

runId string

The data pipeline run identifier.

userIdentity UnifiedUserIdentity

Returns

Task<DataPipelineRun>

The requested data pipeline run object.