本文整理了Java中com.netflix.conductor.common.metadata.tasks.Task.setRetriedTaskId()
方法的一些代码示例,展示了Task.setRetriedTaskId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.setRetriedTaskId()
方法的具体详情如下:
包路径:com.netflix.conductor.common.metadata.tasks.Task
类名称:Task
方法名:setRetriedTaskId
暂无
代码示例来源:origin: Netflix/conductor
/**
* Reschedule a task
*
* @param task failed or cancelled task
* @return new instance of a task with "SCHEDULED" status
*/
private Task taskToBeRescheduled(Task task) {
Task taskToBeRetried = task.copy();
taskToBeRetried.setTaskId(IDGenerator.generate());
taskToBeRetried.setRetriedTaskId(task.getTaskId());
taskToBeRetried.setStatus(SCHEDULED);
taskToBeRetried.setRetryCount(task.getRetryCount() + 1);
taskToBeRetried.setRetried(false);
taskToBeRetried.setPollCount(0);
taskToBeRetried.setCallbackAfterSeconds(0);
task.setRetried(true);
return taskToBeRetried;
}
代码示例来源:origin: Netflix/conductor
simpleTask.setResponseTimeoutSeconds(taskDefinition.getResponseTimeoutSeconds());
simpleTask.setWorkflowTask(taskToSchedule);
simpleTask.setRetriedTaskId(retriedTaskId);
return Collections.singletonList(simpleTask);
代码示例来源:origin: Netflix/conductor
rescheduled.setRetried(false);
rescheduled.setTaskId(IDGenerator.generate());
rescheduled.setRetriedTaskId(task.getTaskId());
rescheduled.setStatus(SCHEDULED);
rescheduled.setPollCount(0);
代码示例来源:origin: Netflix/conductor
to.setUpdateTime( from.getUpdateTime() );
to.setStartDelayInSeconds( from.getStartDelayInSeconds() );
to.setRetriedTaskId( from.getRetriedTaskId() );
to.setRetried( from.getRetried() );
to.setExecuted( from.getExecuted() );
代码示例来源:origin: Netflix/conductor
dynamicTask.setWorkflowTask(taskToSchedule);
dynamicTask.setTaskType(taskName);
dynamicTask.setRetriedTaskId(retriedTaskId);
return Collections.singletonList(dynamicTask);
代码示例来源:origin: com.netflix.conductor/conductor-core
/**
* Reschedule a task
*
* @param task failed or cancelled task
* @return new instance of a task with "SCHEDULED" status
*/
private Task taskToBeRescheduled(Task task) {
Task taskToBeRetried = task.copy();
taskToBeRetried.setTaskId(IDGenerator.generate());
taskToBeRetried.setRetriedTaskId(task.getTaskId());
taskToBeRetried.setStatus(SCHEDULED);
taskToBeRetried.setRetryCount(task.getRetryCount() + 1);
taskToBeRetried.setRetried(false);
taskToBeRetried.setPollCount(0);
taskToBeRetried.setCallbackAfterSeconds(0);
task.setRetried(true);
return taskToBeRetried;
}
代码示例来源:origin: com.netflix.conductor/conductor-core
simpleTask.setResponseTimeoutSeconds(taskDefinition.getResponseTimeoutSeconds());
simpleTask.setWorkflowTask(taskToSchedule);
simpleTask.setRetriedTaskId(retriedTaskId);
return Collections.singletonList(simpleTask);
代码示例来源:origin: com.netflix.conductor/conductor-core
rescheduled.setRetried(false);
rescheduled.setTaskId(IDGenerator.generate());
rescheduled.setRetriedTaskId(task.getTaskId());
rescheduled.setStatus(SCHEDULED);
rescheduled.setPollCount(0);
代码示例来源:origin: com.netflix.conductor/conductor-grpc
to.setUpdateTime( from.getUpdateTime() );
to.setStartDelayInSeconds( from.getStartDelayInSeconds() );
to.setRetriedTaskId( from.getRetriedTaskId() );
to.setRetried( from.getRetried() );
to.setExecuted( from.getExecuted() );
代码示例来源:origin: com.netflix.conductor/conductor-core
dynamicTask.setWorkflowTask(taskToSchedule);
dynamicTask.setTaskType(taskName);
dynamicTask.setRetriedTaskId(retriedTaskId);
return Collections.singletonList(dynamicTask);
内容来源于网络,如有侵权,请联系作者删除!