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

Task.setWorkerId介绍

暂无

代码示例

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

@Test
public void testBatchPoll() throws Exception{
  Task task = new Task();
  task.setTaskType("SIMPLE");
  task.setWorkerId("123");
  task.setDomain("test");
  List<Task> listOfTasks = new ArrayList<>();
  listOfTasks.add(task);
  when(mockTaskService.batchPoll(anyString(), anyString(), anyString(), anyInt(), anyInt())).thenReturn(listOfTasks);
  assertEquals(listOfTasks, taskResource.batchPoll("SIMPLE", "123",
      "test", 1, 100));
}

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

@Test
public void testGetInProgressTasks() throws Exception {
  Task task = new Task();
  task.setTaskType("SIMPLE");
  task.setWorkerId("123");
  task.setDomain("test");
  task.setStatus(Task.Status.IN_PROGRESS);
  List<Task> listOfTasks = new ArrayList<>();
  listOfTasks.add(task);
  when(mockTaskService.getTasks(anyString(), anyString(), anyInt())).thenReturn(listOfTasks);
  assertEquals(listOfTasks, taskResource.getTasks("SIMPLE", "123", 123));
}

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

@Test
public void testPoll() throws Exception {
  Task task = new Task();
  task.setTaskType("SIMPLE");
  task.setWorkerId("123");
  task.setDomain("test");
  when(mockTaskService.poll(anyString(), anyString(), anyString())).thenReturn(task);
  assertEquals(task, taskResource.poll("SIMPLE", "123", "test"));
}

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

@Test
public void testGetPendingTaskForWorkflow() {
  Task task = new Task();
  task.setTaskType("SIMPLE");
  task.setWorkerId("123");
  task.setDomain("test");
  task.setStatus(Task.Status.IN_PROGRESS);
  when(mockTaskService.getPendingTaskForWorkflow(anyString(), anyString())).thenReturn(task);
  assertEquals(task, taskResource.getPendingTaskForWorkflow("SIMPLE", "123"));
}

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

@Override
public void start(Workflow workflow, Task task, WorkflowExecutor executor) {
  Object request = task.getInputData().get(requestParameter);
  task.setWorkerId(config.getServerId());
  if(request == null) {
    task.setReasonForIncompletion(MISSING_REQUEST);

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

@Test
  public void search() {
    Task task = new Task();
    task.setTaskType("SIMPLE");
    task.setWorkerId("123");
    task.setDomain("test");
    task.setStatus(Task.Status.IN_PROGRESS);
    TaskSummary taskSummary = new TaskSummary(task);
    ArrayList<TaskSummary> listOfTaskSummary = new ArrayList<TaskSummary>() {{
      add(taskSummary);
    }};
    SearchResult<TaskSummary> searchResult = new SearchResult<TaskSummary>(100, listOfTaskSummary);
    listOfTaskSummary.add(taskSummary);

    when(mockTaskService.search(anyInt(), anyInt(), anyString(), anyString(), anyString())).thenReturn(searchResult);
    assertEquals(searchResult, taskResource.search(0,100,"asc", "*", "*"));
  }
}

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

@Test
public void testGetTask() throws Exception {
  Task task = new Task();
  task.setTaskType("SIMPLE");
  task.setWorkerId("123");
  task.setDomain("test");
  task.setStatus(Task.Status.IN_PROGRESS);
  when(mockTaskService.getTask(anyString())).thenReturn(task);
  assertEquals(task, taskResource.getTask("123"));
}

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

task.setWorkerId(workerId);
task.setPollCount(task.getPollCount() + 1);
executionDAOFacade.updateTask(task);

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

to.setReasonForIncompletion( from.getReasonForIncompletion() );
to.setCallbackAfterSeconds( from.getCallbackAfterSeconds() );
to.setWorkerId( from.getWorkerId() );
Map<String, Object> outputDataMap = new HashMap<String, Object>();
for (Map.Entry<String, Value> pair : from.getOutputDataMap().entrySet()) {

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

task.setExternalOutputPayloadStoragePath(taskResult.getExternalOutputPayloadStoragePath());
  task.setReasonForIncompletion(taskResult.getReasonForIncompletion());
  task.setWorkerId(taskResult.getWorkerId());
  executionDAOFacade.updateTask(task);
  String msg = String.format("Workflow %s is already completed as %s, task=%s, reason=%s",
task.setExternalOutputPayloadStoragePath(taskResult.getExternalOutputPayloadStoragePath());
task.setReasonForIncompletion(taskResult.getReasonForIncompletion());
task.setWorkerId(taskResult.getWorkerId());
task.setCallbackAfterSeconds(taskResult.getCallbackAfterSeconds());

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

@Override
public void start(Workflow workflow, Task task, WorkflowExecutor executor) {
  Object request = task.getInputData().get(requestParameter);
  task.setWorkerId(config.getServerId());
  if(request == null) {
    task.setReasonForIncompletion(MISSING_REQUEST);

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

task.setWorkerId(workerId);
task.setPollCount(task.getPollCount() + 1);
executionDAOFacade.updateTask(task);

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

to.setReasonForIncompletion( from.getReasonForIncompletion() );
to.setCallbackAfterSeconds( from.getCallbackAfterSeconds() );
to.setWorkerId( from.getWorkerId() );
Map<String, Object> outputDataMap = new HashMap<String, Object>();
for (Map.Entry<String, Value> pair : from.getOutputDataMap().entrySet()) {

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

task.setExternalOutputPayloadStoragePath(taskResult.getExternalOutputPayloadStoragePath());
  task.setReasonForIncompletion(taskResult.getReasonForIncompletion());
  task.setWorkerId(taskResult.getWorkerId());
  executionDAOFacade.updateTask(task);
  String msg = String.format("Workflow %s is already completed as %s, task=%s, reason=%s",
task.setExternalOutputPayloadStoragePath(taskResult.getExternalOutputPayloadStoragePath());
task.setReasonForIncompletion(taskResult.getReasonForIncompletion());
task.setWorkerId(taskResult.getWorkerId());
task.setCallbackAfterSeconds(taskResult.getCallbackAfterSeconds());