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

Task.setInputData介绍

暂无

代码示例

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

@VisibleForTesting
void failTask(Task task, PayloadType payloadType, String errorMsg) {
  logger.error(errorMsg);
  task.setReasonForIncompletion(errorMsg);
  task.setStatus(Task.Status.FAILED_WITH_TERMINAL_ERROR);
  if (payloadType == PayloadType.TASK_INPUT) {
    task.setInputData(null);
  } else {
    task.setOutputData(null);
  }
  throw new TerminateWorkflowException(errorMsg, Workflow.WorkflowStatus.FAILED, task);
}

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

/**
 * Populates the task input from external payload storage if the external storage path is specified.
 *
 * @param task the task for which the input is to be populated.
 */
private void populateTaskInput(Task task) {
  if (StringUtils.isNotBlank(task.getExternalInputPayloadStoragePath())) {
    WorkflowTaskMetrics.incrementExternalPayloadUsedCount(task.getTaskDefName(), ExternalPayloadStorage.Operation.READ.name(), ExternalPayloadStorage.PayloadType.TASK_INPUT.name());
    task.setInputData(downloadFromExternalStorage(ExternalPayloadStorage.PayloadType.TASK_INPUT, task.getExternalInputPayloadStoragePath()));
    task.setExternalInputPayloadStoragePath(null);
  }
}

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

@SuppressWarnings("unchecked")
@Test
public void testUploadTaskPayload() throws IOException {
  AtomicInteger uploadCount = new AtomicInteger(0);
  InputStream stream = ExternalPayloadStorageUtilsTest.class.getResourceAsStream("/payload.json");
  Map<String, Object> payload = objectMapper.readValue(stream, Map.class);
  when(externalPayloadStorage.getLocation(ExternalPayloadStorage.Operation.WRITE, ExternalPayloadStorage.PayloadType.TASK_INPUT, "")).thenReturn(location);
  doAnswer(invocation -> {
    uploadCount.incrementAndGet();
    return null;
  }).when(externalPayloadStorage).upload(anyString(), any(), anyLong());
  Task task = new Task();
  task.setInputData(payload);
  externalPayloadStorageUtils.verifyAndUpload(task, ExternalPayloadStorage.PayloadType.TASK_INPUT);
  assertNull(task.getInputData());
  assertEquals(1, uploadCount.get());
  assertNotNull(task.getExternalInputPayloadStoragePath());
}

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

eventTask.setCorrelationId(workflowInstance.getCorrelationId());
eventTask.setScheduledTime(System.currentTimeMillis());
eventTask.setInputData(eventTaskInput);
eventTask.getInputData().put("sink", sink);
eventTask.setTaskId(taskId);

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

task.setInputData(externalPayloadStorageUtils.downloadPayload(task.getExternalInputPayloadStoragePath()));
Monitors.recordExternalPayloadStorageUsage(task.getTaskDefName(), ExternalPayloadStorage.Operation.READ.toString(), ExternalPayloadStorage.PayloadType.TASK_INPUT.toString());
task.setExternalInputPayloadStoragePath(null);

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

joinTask.setWorkflowType(workflowInstance.getWorkflowName());
joinTask.setScheduledTime(System.currentTimeMillis());
joinTask.setInputData(joinInput);
joinTask.setTaskId(taskId);
joinTask.setStatus(Task.Status.IN_PROGRESS);

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

theTask.setCorrelationId(wf.getCorrelationId());
if (skipTaskRequest != null) {
  theTask.setInputData(skipTaskRequest.getTaskInput());
  theTask.setOutputData(skipTaskRequest.getTaskOutput());
  theTask.setInputMessage(skipTaskRequest.getTaskInputMessage());

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

@Test
public void testFailTaskWithInputPayload() {
  Task task = new Task();
  task.setInputData(new HashMap<>());
  expectedException.expect(TerminateWorkflowException.class);
  externalPayloadStorageUtils.failTask(task, ExternalPayloadStorage.PayloadType.TASK_INPUT, "error");
  assertNotNull(task);
  assertNull(task.getInputData());
}

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

userDefinedTask.setScheduledTime(System.currentTimeMillis());
userDefinedTask.setTaskId(taskId);
userDefinedTask.setInputData(input);
userDefinedTask.setStatus(Task.Status.SCHEDULED);
userDefinedTask.setRetryCount(retryCount);

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

/**
 * This method creates a JOIN task that is used in the {@link this#getMappedTasks(TaskMapperContext)}
 * at the end to add a join task to be scheduled after all the fork tasks
 *
 * @param workflowInstance: A instance of the {@link Workflow} which represents the workflow being executed.
 * @param joinWorkflowTask: A instance of {@link WorkflowTask} which is of type {@link TaskType#JOIN}
 * @param joinInput:        The input which is set in the {@link Task#setInputData(Map)}
 * @return a new instance of {@link Task} representing a {@link SystemTaskType#JOIN}
 */
@VisibleForTesting
Task createJoinTask(Workflow workflowInstance, WorkflowTask joinWorkflowTask, HashMap<String, Object> joinInput) {
  Task joinTask = new Task();
  joinTask.setTaskType(SystemTaskType.JOIN.name());
  joinTask.setTaskDefName(SystemTaskType.JOIN.name());
  joinTask.setReferenceTaskName(joinWorkflowTask.getTaskReferenceName());
  joinTask.setWorkflowInstanceId(workflowInstance.getWorkflowId());
  joinTask.setWorkflowType(workflowInstance.getWorkflowName());
  joinTask.setCorrelationId(workflowInstance.getCorrelationId());
  joinTask.setScheduledTime(System.currentTimeMillis());
  joinTask.setInputData(joinInput);
  joinTask.setTaskId(IDGenerator.generate());
  joinTask.setStatus(Task.Status.IN_PROGRESS);
  joinTask.setWorkflowTask(joinWorkflowTask);
  return joinTask;
}

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

forkTask.setScheduledTime(System.currentTimeMillis());
forkTask.setEndTime(System.currentTimeMillis());
forkTask.setInputData(taskInput);
forkTask.setTaskId(taskId);
forkTask.setStatus(Task.Status.COMPLETED);

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

@Override
  public List<Task> getMappedTasks(TaskMapperContext taskMapperContext) {

    logger.debug("TaskMapperContext {} in WaitTaskMapper", taskMapperContext);

    WorkflowTask taskToSchedule = taskMapperContext.getTaskToSchedule();
    Workflow workflowInstance = taskMapperContext.getWorkflowInstance();
    String taskId = taskMapperContext.getTaskId();

    Map<String, Object> waitTaskInput = parametersUtils.getTaskInputV2(taskMapperContext.getTaskToSchedule().getInputParameters(),
        workflowInstance, taskId, null);

    Task waitTask = new Task();
    waitTask.setTaskType(Wait.NAME);
    waitTask.setTaskDefName(taskMapperContext.getTaskToSchedule().getName());
    waitTask.setReferenceTaskName(taskMapperContext.getTaskToSchedule().getTaskReferenceName());
    waitTask.setWorkflowInstanceId(workflowInstance.getWorkflowId());
    waitTask.setWorkflowType(workflowInstance.getWorkflowName());
    waitTask.setCorrelationId(workflowInstance.getCorrelationId());
    waitTask.setScheduledTime(System.currentTimeMillis());
    waitTask.setInputData(waitTaskInput);
    waitTask.setTaskId(taskId);
    waitTask.setStatus(Task.Status.IN_PROGRESS);
    waitTask.setWorkflowTask(taskToSchedule);
    return Collections.singletonList(waitTask);
  }
}

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

httpTask.setScheduledTime(System.currentTimeMillis());
httpTask.setTaskId(taskId);
httpTask.setInputData(input);
httpTask.setStatus(Task.Status.SCHEDULED);
httpTask.setRetryCount(retryCount);

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

simpleTask.setTaskId(taskMapperContext.getTaskId());
simpleTask.setReferenceTaskName(taskToSchedule.getTaskReferenceName());
simpleTask.setInputData(input);
simpleTask.setWorkflowInstanceId(workflowInstance.getWorkflowId());
simpleTask.setWorkflowType(workflowInstance.getWorkflowName());

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

rescheduled.setStatus(SCHEDULED);
rescheduled.setPollCount(0);
rescheduled.setInputData(new HashMap<>());
rescheduled.getInputData().putAll(task.getInputData());
rescheduled.setReasonForIncompletion(null);

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

inputDataMap.put( pair.getKey(), fromProto( pair.getValue() ) );
to.setInputData(inputDataMap);
to.setReferenceTaskName( from.getReferenceTaskName() );
to.setRetryCount( from.getRetryCount() );

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

@Test
public void indexTask() throws Exception {
  String correlationId = "some-correlation-id";
  Task task = new Task();
  task.setTaskId("some-task-id");
  task.setWorkflowInstanceId("some-workflow-instance-id");
  task.setTaskType("some-task-type");
  task.setStatus(Status.FAILED);
  task.setInputData(new HashMap<String, Object>() {{ put("input_key", "input_value"); }});
  task.setCorrelationId(correlationId);
  task.setTaskDefName("some-task-def-name");
  task.setReasonForIncompletion("some-failure-reason");
  indexDAO.indexTask(task);
  await()
      .atMost(5, TimeUnit.SECONDS)
      .untilAsserted(() -> {
        SearchResult<String> result = indexDAO
            .searchTasks("correlationId='" + correlationId + "'", "*", 0, 10000, null);
        assertTrue("should return 1 or more search results", result.getResults().size() > 0);
        assertEquals("taskId should match the indexed task", "some-task-id", result.getResults().get(0));
      });
}

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

@Test
public void indexTask() throws Exception {
  String correlationId = "some-correlation-id";
  Task task = new Task();
  task.setTaskId("some-task-id");
  task.setWorkflowInstanceId("some-workflow-instance-id");
  task.setTaskType("some-task-type");
  task.setStatus(Status.FAILED);
  task.setInputData(new HashMap<String, Object>() {{ put("input_key", "input_value"); }});
  task.setCorrelationId(correlationId);
  task.setTaskDefName("some-task-def-name");
  task.setReasonForIncompletion("some-failure-reason");
  indexDAO.indexTask(task);
  await()
      .atMost(5, TimeUnit.SECONDS)
      .untilAsserted(() -> {
        SearchResult<String> result = indexDAO
            .searchTasks("correlationId='" + correlationId + "'", "*", 0, 10000, null);
        assertTrue("should return 1 or more search results", result.getResults().size() > 0);
        assertEquals("taskId should match the indexed task", "some-task-id", result.getResults().get(0));
      });
}

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

dynamicTask.setTaskId(taskMapperContext.getTaskId());
dynamicTask.setReferenceTaskName(taskToSchedule.getTaskReferenceName());
dynamicTask.setInputData(input);
dynamicTask.setWorkflowInstanceId(workflowInstance.getWorkflowId());
dynamicTask.setWorkflowType(workflowInstance.getWorkflowName());

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