TaskService

@Service

class TaskService(config: TaskControllerConfig, transactionTemplate: TransactionTemplate, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorsRepo: ErrorRepo, var executorRepo: ExecutorRepo, var executorTypeRepo: TaskExecutorTypeRepo, authorizer: Authorizer, @Lazy tasksActorApi: TasksActorApi, executionEngine: ExecutionEngine? = null) : TaskServiceBase, TaskServiceApi

Constructors

constructor(config: TaskControllerConfig, transactionTemplate: TransactionTemplate, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorsRepo: ErrorRepo, executorRepo: ExecutorRepo, executorTypeRepo: TaskExecutorTypeRepo, authorizer: Authorizer, @Lazy tasksActorApi: TasksActorApi, executionEngine: ExecutionEngine? = null)

fun cancelTask(authData: AuthData?, taskId: TaskId, tenantId: Int): TaskEntity

open override fun createTask(authData: AuthData?, request: TaskRequest): Task

open override fun createTask(authData: AuthData?, request: TaskRequest, pipelineTaskId: TaskId?): Task

fun getPipelineTasksResults(authData: AuthData?, pipelineTaskId: TaskId, taskTypeHids: List<String>?, pageable: Pageable): Page<PipelineTaskResult>

fun getTaskEntity(authData: AuthData?, taskId: Long, tenantId: Int): TaskEntity

fun getTaskInput(authData: AuthData?, taskId: Long, tenantId: Int): TaskData?

fun getTaskResult(authData: AuthData, taskId: Long, tenantId: Int): TaskResult

fun getTasks(authData: AuthData?, pageable: Pageable, tenantId: Int, runningStatuses: List<Task.RunningStatus> = emptyList(), taskTypeHids: List<String> = emptyList(), taskTypeCategory: TaskTypeCategory? = null, extId: String? = null, pipelineTaskId: TaskId? = null): Page<TaskWithProgress>

open fun lookupExecutor(executorHid: String, executorTypeHid: String): Executor

fun rerunTask(authData: AuthData?, taskId: TaskId, tenantId: Int): TaskEntity

fun startTask(authData: AuthData?, taskId: TaskId, tenantId: Int): TaskEntity

fun takeTaskForExecution(httpHeaders: HttpHeaders, executorTypeHid: String, executorHid: String): TaskEntity?

fun takeTaskForExecutionWaiting(httpHeaders: HttpHeaders, executorTypeHid: String, executorHid: String): TaskTakeForExecutionResult