public WorkResult process()

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