类的使用
cn.feiliu.taskflow.common.metadata.tasks.ExecutingTask

使用ExecutingTask的程序包

程序包	说明
cn.feiliu.taskflow.common.metadata.tasks
cn.feiliu.taskflow.common.run
cn.feiliu.taskflow.mapper
cn.feiliu.taskflow.open.api
cn.feiliu.taskflow.sdk.worker
cn.feiliu.taskflow.sdk.workflow.executor.task

cn.feiliu.taskflow.common.metadata.tasks中ExecutingTask的使用

返回ExecutingTask的cn.feiliu.taskflow.common.metadata.tasks中的方法

修饰符和类型	方法	说明
ExecutingTask	ExecutingTask.copy()
ExecutingTask	ExecutingTask.deepCopy()

参数类型为ExecutingTask的cn.feiliu.taskflow.common.metadata.tasks中的构造器

构造器	说明
TaskExecResult(ExecutingTask task)

cn.feiliu.taskflow.common.run中ExecutingTask的使用

返回ExecutingTask的cn.feiliu.taskflow.common.run中的方法

修饰符和类型	方法	说明
ExecutingTask	ExecutingWorkflow.getTaskByRefName(String refName)

cn.feiliu.taskflow.mapper中ExecutingTask的使用

返回ExecutingTask的cn.feiliu.taskflow.mapper中的方法

修饰符和类型	方法	说明
ExecutingTask	MapperFactory.fromProto(cn.feiliu.taskflow.proto.TaskModelPb.Task from)

参数类型为ExecutingTask的cn.feiliu.taskflow.mapper中的方法

修饰符和类型	方法	说明
cn.feiliu.taskflow.proto.TaskModelPb.Task	MapperFactory.toProto(ExecutingTask from)

cn.feiliu.taskflow.open.api中ExecutingTask的使用

返回ExecutingTask的cn.feiliu.taskflow.open.api中的方法

修饰符和类型	方法	说明
ExecutingTask	ITaskService.getTaskDetails(String taskId)	Retrieve information about the task
ExecutingTask	ITaskService.pollTask(String taskType, String workerId, String domain)	Perform a poll for a task of a specific task type.

返回变量类型为ExecutingTask的类型的cn.feiliu.taskflow.open.api中的方法

修饰符和类型	方法	说明
List<ExecutingTask>	ITaskService.batchPollTasksByTaskType(String taskType, String workerId, int count, int timeoutInMillisecond)	Perform a batch poll for tasks by task type.
List<ExecutingTask>	ITaskService.batchPollTasksInDomain(String taskType, String domain, String workerId, int count, int timeoutInMillisecond)	Batch poll for tasks in a domain.

cn.feiliu.taskflow.sdk.worker中ExecutingTask的使用

参数类型为ExecutingTask的cn.feiliu.taskflow.sdk.worker中的方法

修饰符和类型	方法	说明
TaskExecResult	Worker.execute(ExecutingTask task)	Executes a task and returns the updated task.
default void	Worker.onErrorUpdate(ExecutingTask task)	Called when the task coordinator fails to update the task to the server.

类型变量类型为ExecutingTask的cn.feiliu.taskflow.sdk.worker中的方法参数

修饰符和类型	方法	说明
static Worker	Worker.create(String taskType, Function<ExecutingTask,TaskExecResult> executor)

cn.feiliu.taskflow.sdk.workflow.executor.task中ExecutingTask的使用

返回ExecutingTask的cn.feiliu.taskflow.sdk.workflow.executor.task中的方法

修饰符和类型	方法	说明
ExecutingTask	TaskContext.getTask()

参数类型为ExecutingTask的cn.feiliu.taskflow.sdk.workflow.executor.task中的方法

修饰符和类型	方法	说明
TaskExecResult	AnnotatedWorker.execute(ExecutingTask task)
TaskExecResult	DynamicForkWorker.execute(ExecutingTask task)
static TaskContext	TaskContext.set(ExecutingTask task)

参数类型为ExecutingTask的cn.feiliu.taskflow.sdk.workflow.executor.task中的构造器

构造器	说明
TaskContext(ExecutingTask task, TaskExecResult taskResult)