PipelineControllerMonitorApi

API available to pipeline controller code for creating connected tasks, reading their results, marking task creation boundaries, and finishing a pipeline.

See the pipeline lifecycle guide.

Inheritors

Functions

Link copied to clipboard
abstract fun createTask(pipelineTaskId: TaskId, request: TaskRequest)
Link copied to clipboard
abstract fun finishPipeline(taskId: TaskId, taskTypeHid: String, result: TaskResult)
Link copied to clipboard
abstract fun getPipelineTasksResults(pipelineTaskId: TaskId, taskTypeHids: List<String>? = null): Sequence<PipelineTaskResult>
Link copied to clipboard
abstract fun pipelineIsDoneCreatingTasks(pipelineTaskId: TaskId)
abstract fun pipelineIsDoneCreatingTasks(pipelineTaskId: TaskId, taskTypeHid: String)