com.netflix.conductor.common.metadata.tasks.Task.setRetriedTaskId()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(3.3k)|赞(0)|评价(0)|浏览(105)

本文整理了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

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);

相关文章

微信公众号

最新文章

更多

Task类方法