import { TaskRef } from './TaskRef'; import { TaskExchangeRef } from './TaskExchangeRef'; import { ITaskRunnerOptions } from './ITaskRunnerOptions'; import { ITaskExectorOptions } from './ITaskExectorOptions'; import { TASK_RUNNER_SPEC } from './Constants'; import { RuntimeLoader } from '../../base/RuntimeLoader'; import { Tasks } from './Tasks'; import { TaskRunner } from './TaskRunner'; import { System } from '../system/System'; export declare class TasksHelper { static getIncomingParameters(tasks: TaskRef[], withoutPassThrough?: boolean): TaskExchangeRef[]; static prepare(tasks: Tasks, loader: RuntimeLoader, hasWorker?: boolean): void; static addClasses(tasks: Tasks, dir: string): Promise; static runner(tasks: Tasks, name: TASK_RUNNER_SPEC | TASK_RUNNER_SPEC[], options: ITaskRunnerOptions): TaskRunner; static getTaskLogFile(runnerId: string, nodeId: string, relative?: boolean, options?: { parseDate: boolean; }): string; /** * Return task names from task specification * * @param taskSpec */ static getTaskNames(taskSpec: TASK_RUNNER_SPEC[]): string[]; /** * Extract task relevant parameters from passed keys * @param argv */ static extractOptions(argv: ITaskExectorOptions): {}; /** * Helper analysing parameters and executes local or remote execution * * @Deprecated use TaskExecutor instead * * ``` * const executor = Injector.create(TaskExecutor); * const running = await executor1 * .create( * ['simple_task_running'], * {}, * { * executionConcurrency: 1, * waitForRemoteResults: true, * targetId: 'system_0', * skipTargetCheck: true, * }) * .run(); * ``` * * @param taskSpec * @param argv */ static exec(taskSpec: TASK_RUNNER_SPEC[], argv: ITaskExectorOptions): Promise; static getWorkerNodes(system: System): string[]; static getTaskParameters(argv?: any): any; }