in src/main/java/com/amazonaws/codepipeline/jobworker/CodePipelineJobProcessor.java [40:58]
public WorkResult process(final WorkItem workItem) {
final Map<String, String> actionCofiguration = workItem.getJobData().getActionConfiguration();
// for testing purposes: if the job was configured to fail, return a failure
if (actionCofiguration.containsKey(JOB_STATUS)) {
if (actionCofiguration.get(JOB_STATUS).equals(JobStatus.Failed.toString())) {
return WorkResult.failure(
workItem.getJobId(),
new FailureDetails(FailureType.JobFailed, "job failed"));
}
}
return WorkResult.success(
workItem.getJobId(),
new ExecutionDetails("test summary", UUID.randomUUID().toString(), 100),
new CurrentRevision("test revision", "test change identifier"));
}