@Test
@SneakyThrows
public void shouldCreateJobIfNoRunning() {

  Source source = DataGenerator.createSource("kafka:9092", "topic");
  Store store = DataGenerator.getDefaultStore();
  when(specService.listFeatureSets(
          CoreServiceProto.ListFeatureSetsRequest.newBuilder()
              .setFilter(Filter.newBuilder().setFeatureSetName("*").setProject("*").build())
              .build()))
      .thenReturn(ListFeatureSetsResponse.newBuilder().build());
  List<JobTask> tasks =
      controllerWithConsolidation.makeJobUpdateTasks(
          ImmutableList.of(Pair.of(source, ImmutableSet.of(store))));
  assertThat(tasks.get(0).getJob().getId(), containsString("test-prefix"));
  assertThat("CreateTask is expected", tasks.get(0) instanceof CreateJobTask);
}