@Test
public void shouldCheckStatusOfAbortingJob() {

  Source source = DataGenerator.createSource("kafka:9092", "topic");
  Store store = DataGenerator.getDefaultStore();
  Job job =
      Job.builder()
          .setSource(source)
          .setStores(ImmutableMap.of(store.getName(), store))
          .setId("some-id")
          .build();
  job.setStatus(JobStatus.ABORTING);
  job.setExtId("extId");
  jobRepository.add(job);
  List<JobTask> tasks =
      controllerWithConsolidation.makeJobUpdateTasks(
          ImmutableList.of(Pair.of(source, ImmutableSet.of(store))));
  assertThat("CheckStatus is expected", tasks.get(0) instanceof UpdateJobStatusTask);
}