in genie-web/src/integTest/java/com/netflix/genie/web/data/services/impl/jpa/JpaPersistenceServiceImplJobsIntegrationTest.java [734:819]
void canFindJobsWithTags() {
final Pageable page = PageRequest.of(0, 10);
Page<JobSearchResult> jobs;
jobs = this.service.findJobs(
null,
null,
null,
null,
Sets.newHashSet("SparkJob"),
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
jobs = this.service.findJobs(
null,
null,
null,
null,
Sets.newHashSet("smoke-test", "SparkJob"),
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,
Sets.newHashSet("smoke-test", "SparkJob", "blah"),
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
jobs = this.service.findJobs(
null,
null,
null,
Sets.newHashSet(com.netflix.genie.common.dto.JobStatus.FAILED),
Sets.newHashSet("smoke-test", "SparkJob"),
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
}