in src/main/java/com/amazonaws/codepipeline/jobworker/plugin/customaction/CustomActionJobService.java [69:82]
public List<WorkItem> pollForJobs(final int maxBatchSize) {
LOGGER.info(String.format("PollForJobs for action type id %s", actionTypeId));
final List<WorkItem> result = new ArrayList<>();
final PollForJobsRequest pollForJobsRequest = new PollForJobsRequest();
pollForJobsRequest.setActionTypeId(getActionTypeId());
pollForJobsRequest.setMaxBatchSize(maxBatchSize);
final PollForJobsResult pollForJobsResult = codePipelineClient.pollForJobs(pollForJobsRequest);
for (final Job job : pollForJobsResult.getJobs()) {
result.add(JobConverter.convert(job));
}
return result;
}