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

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

本文整理了Java中com.netflix.conductor.common.metadata.tasks.Task.setRetryCount()方法的一些代码示例，展示了Task.setRetryCount()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Task.setRetryCount()方法的具体详情如下：
包路径：com.netflix.conductor.common.metadata.tasks.Task
类名称：Task
方法名：setRetryCount

Task.setRetryCount介绍

暂无

代码示例

代码示例来源：origin: Netflix/conductor

task.setStatus(SCHEDULED);
  task.setRetried(true);
  task.setRetryCount(0);
  return task;
})

代码示例来源：origin: Netflix/conductor

task1.setRetryCount(1);
task2.setRetryCount(2);
newTask.setRetryCount(0);

代码示例来源：origin: Netflix/conductor

userDefinedTask.setInputData(input);
userDefinedTask.setStatus(Task.Status.SCHEDULED);
userDefinedTask.setRetryCount(retryCount);
userDefinedTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
userDefinedTask.setWorkflowTask(taskToSchedule);

代码示例来源：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

httpTask.setInputData(input);
httpTask.setStatus(Task.Status.SCHEDULED);
httpTask.setRetryCount(retryCount);
httpTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
httpTask.setWorkflowTask(taskToSchedule);

代码示例来源：origin: Netflix/conductor

task.setTaskId(workflowId + "_t" + i);
  task.setReferenceTaskName("t" + i);
  task.setRetryCount(0);
  task.setWorkflowInstanceId(workflowId);
  task.setTaskDefName("task" + i);
task.setTaskId(workflowId + "_t" + 2);
task.setReferenceTaskName("t" + 2);
task.setRetryCount(1);
task.setWorkflowInstanceId(workflowId);
task.setTaskDefName("task" + 2);
task.setTaskId(workflowId + "_t" + 1);
task.setReferenceTaskName("t" + 1);
task.setRetryCount(0);
task.setWorkflowInstanceId(workflowId);
task.setTaskDefName("task" + 1);

代码示例来源：origin: Netflix/conductor

simpleTask.setCorrelationId(workflowInstance.getCorrelationId());
simpleTask.setScheduledTime(System.currentTimeMillis());
simpleTask.setRetryCount(retryCount);
simpleTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
simpleTask.setResponseTimeoutSeconds(taskDefinition.getResponseTimeoutSeconds());

代码示例来源：origin: Netflix/conductor

task_1_1.setTaskId(UUID.randomUUID().toString());
task_1_1.setSeq(20);
task_1_1.setRetryCount(0);
task_1_1.setTaskType(TaskType.SIMPLE.toString());
task_1_1.setStatus(Status.CANCELED);
task_1_2.setTaskId(UUID.randomUUID().toString());
task_1_2.setSeq(21);
task_1_2.setRetryCount(1);
task_1_2.setTaskType(TaskType.SIMPLE.toString());
task_1_2.setStatus(Status.FAILED);
task_2_1.setTaskId(UUID.randomUUID().toString());
task_2_1.setSeq(22);
task_2_1.setRetryCount(0);
task_2_1.setStatus(Status.FAILED);
task_2_1.setTaskType(TaskType.SIMPLE.toString());
task_3_1.setTaskId(UUID.randomUUID().toString());
task_3_1.setSeq(23);
task_3_1.setRetryCount(0);
task_3_1.setStatus(Status.CANCELED);
task_3_1.setTaskType(TaskType.SIMPLE.toString());
task_4_1.setTaskId(UUID.randomUUID().toString());
task_4_1.setSeq(122);
task_4_1.setRetryCount(0);
task_4_1.setStatus(Status.FAILED);
task_4_1.setTaskType(TaskType.SIMPLE.toString());

代码示例来源：origin: Netflix/conductor

task.setTaskId(workflowId + "_t" + i);
task.setReferenceTaskName("testTaskOps" + i);
task.setRetryCount(0);
task.setWorkflowInstanceId(workflowId);
task.setTaskDefName("testTaskOps" + i);
task.setTaskId("x" + workflowId + "_t" + i);
task.setReferenceTaskName("testTaskOps" + i);
task.setRetryCount(0);
task.setWorkflowInstanceId("x" + workflowId);
task.setTaskDefName("testTaskOps" + i);

代码示例来源：origin: Netflix/conductor

rescheduled.setStartDelayInSeconds(startDelay);
rescheduled.setCallbackAfterSeconds(startDelay);
rescheduled.setRetryCount(task.getRetryCount() + 1);
rescheduled.setRetried(false);
rescheduled.setTaskId(IDGenerator.generate());

代码示例来源：origin: Netflix/conductor

to.setRetryCount( from.getRetryCount() );
to.setSeq( from.getSeq() );
to.setCorrelationId( from.getCorrelationId() );

代码示例来源：origin: Netflix/conductor

task1.setInputData(new HashMap<>());
task1.setStatus(Status.SCHEDULED);
task1.setRetryCount(0);
task1.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
task1.setWorkflowTask(taskToSchedule);
task3.setInputData(new HashMap<>());
task3.setStatus(Status.SCHEDULED);
task3.setRetryCount(0);
task3.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
task3.setWorkflowTask(taskToSchedule);

代码示例来源：origin: Netflix/conductor

dynamicTask.setCorrelationId(workflowInstance.getCorrelationId());
dynamicTask.setScheduledTime(System.currentTimeMillis());
dynamicTask.setRetryCount(retryCount);
dynamicTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
dynamicTask.setResponseTimeoutSeconds(taskDefinition.getResponseTimeoutSeconds());

代码示例来源：origin: Netflix/conductor

public Task copy() {
  Task copy = new Task();
  copy.setCallbackAfterSeconds(callbackAfterSeconds);
  copy.setCallbackFromWorker(callbackFromWorker);
  copy.setCorrelationId(correlationId);
  copy.setInputData(inputData);
  copy.setOutputData(outputData);
  copy.setReferenceTaskName(referenceTaskName);
  copy.setStartDelayInSeconds(startDelayInSeconds);
  copy.setTaskDefName(taskDefName);
  copy.setTaskType(taskType);
  copy.setWorkflowInstanceId(workflowInstanceId);
  copy.setWorkflowType(workflowType);
  copy.setResponseTimeoutSeconds(responseTimeoutSeconds);
  copy.setStatus(status);
  copy.setRetryCount(retryCount);
  copy.setPollCount(pollCount);
  copy.setTaskId(taskId);
  copy.setWorkflowTask(workflowTask);
  copy.setDomain(domain);
  copy.setInputMessage(inputMessage);
  copy.setOutputMessage(outputMessage);
  copy.setRateLimitPerFrequency(rateLimitPerFrequency);
  copy.setRateLimitFrequencyInSeconds(rateLimitFrequencyInSeconds);
  copy.setExternalInputPayloadStoragePath(externalInputPayloadStoragePath);
  copy.setExternalOutputPayloadStoragePath(externalOutputPayloadStoragePath);
  return copy;
}

代码示例来源：origin: com.netflix.conductor/conductor-core

task.setStatus(SCHEDULED);
  task.setRetried(true);
  task.setRetryCount(0);
  return task;
})

代码示例来源：origin: com.netflix.conductor/conductor-core

httpTask.setInputData(input);
httpTask.setStatus(Task.Status.SCHEDULED);
httpTask.setRetryCount(retryCount);
httpTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
httpTask.setWorkflowTask(taskToSchedule);

代码示例来源：origin: com.netflix.conductor/conductor-core

userDefinedTask.setInputData(input);
userDefinedTask.setStatus(Task.Status.SCHEDULED);
userDefinedTask.setRetryCount(retryCount);
userDefinedTask.setCallbackAfterSeconds(taskToSchedule.getStartDelay());
userDefinedTask.setWorkflowTask(taskToSchedule);

代码示例来源：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

rescheduled.setStartDelayInSeconds(startDelay);
rescheduled.setCallbackAfterSeconds(startDelay);
rescheduled.setRetryCount(task.getRetryCount() + 1);
rescheduled.setRetried(false);
rescheduled.setTaskId(IDGenerator.generate());

代码示例来源：origin: com.netflix.conductor/conductor-common

public Task copy() {
  Task copy = new Task();
  copy.setCallbackAfterSeconds(callbackAfterSeconds);
  copy.setCallbackFromWorker(callbackFromWorker);
  copy.setCorrelationId(correlationId);
  copy.setInputData(inputData);
  copy.setOutputData(outputData);
  copy.setReferenceTaskName(referenceTaskName);
  copy.setStartDelayInSeconds(startDelayInSeconds);
  copy.setTaskDefName(taskDefName);
  copy.setTaskType(taskType);
  copy.setWorkflowInstanceId(workflowInstanceId);
  copy.setWorkflowType(workflowType);
  copy.setResponseTimeoutSeconds(responseTimeoutSeconds);
  copy.setStatus(status);
  copy.setRetryCount(retryCount);
  copy.setPollCount(pollCount);
  copy.setTaskId(taskId);
  copy.setWorkflowTask(workflowTask);
  copy.setDomain(domain);
  copy.setInputMessage(inputMessage);
  copy.setOutputMessage(outputMessage);
  copy.setRateLimitPerFrequency(rateLimitPerFrequency);
  copy.setRateLimitFrequencyInSeconds(rateLimitFrequencyInSeconds);
  copy.setExternalInputPayloadStoragePath(externalInputPayloadStoragePath);
  copy.setExternalOutputPayloadStoragePath(externalOutputPayloadStoragePath);
  return copy;
}

内容来源于网络，如有侵权，请联系作者删除！

task

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Task类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com