import type { Promisable, ReadonlyDeep } from 'type-fest'; import type { PipelineJson } from '../../pipeline/PipelineJson/PipelineJson'; import type { TaskProgress } from '../../types/TaskProgress'; import type { Parameters } from '../../types/typeAliases'; import type { PipelineExecutorResult } from '../PipelineExecutorResult'; import type { CreatePipelineExecutorOptions } from './00-CreatePipelineExecutorOptions'; /** * @@@ * * @private internal type of `executePipeline` */ type ExecutePipelineOptions = CreatePipelineExecutorOptions & { /** * @@@ */ readonly inputParameters: Readonly; /** * @@@ */ onProgress?(taskProgress: TaskProgress): Promisable; /** * @@@ */ readonly pipeline: PipelineJson; /** * @@@ */ readonly preparedPipeline: ReadonlyDeep; /** * @@@ */ readonly setPreparedPipeline: (preparedPipeline: ReadonlyDeep) => void; /** * @@@ */ readonly pipelineIdentification: string; }; /** * @@@ * * Note: This is not a `PipelineExecutor` (which is binded with one exact pipeline), but a utility function of `createPipelineExecutor` which creates `PipelineExecutor` * * @private internal utility of `createPipelineExecutor` */ export declare function executePipeline(options: ExecutePipelineOptions): Promise; export {}; /** * TODO: [🐚] Change onProgress to object that represents the running execution, can be subscribed via RxJS to and also awaited */