in genie-web/src/integTest/java/com/netflix/genie/web/data/services/impl/jpa/JpaPersistenceServiceImplJobsIntegrationTest.java [602:730]
void canFindJobs() {
//TODO: add more cases
final Pageable page = PageRequest.of(0, 10, Sort.Direction.DESC, "updated");
Page<JobSearchResult> jobs;
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
jobs = this.service.findJobs(
null,
null,
null,
Sets.newHashSet(com.netflix.genie.common.dto.JobStatus.RUNNING),
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(3L);
Assertions.assertThat(jobs.getContent()).hasSize(3).extracting(BaseSearchResult::getId).contains(JOB_3_ID);
jobs = this.service.findJobs(
JOB_1_ID,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(1L);
Assertions.assertThat(jobs.getContent()).hasSize(1).extracting(BaseSearchResult::getId).containsOnly(JOB_1_ID);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
"job3Grouping",
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(1L);
Assertions.assertThat(jobs.getContent()).hasSize(1).extracting(BaseSearchResult::getId).containsOnly(JOB_3_ID);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
"job2%",
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(1L);
Assertions.assertThat(jobs.getContent()).hasSize(1).extracting(BaseSearchResult::getId).containsOnly(JOB_2_ID);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
"job1%",
"job2%",
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
}