feast-dev
diff --git a/‎job-controller/src/test/java/feast/jobcontroller/service/JobControllerIT.java‎
Lines changed: 4 additions & 0 deletions b/‎job-controller/src/test/java/feast/jobcontroller/service/JobControllerIT.java‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎job-controller/src/test/java/feast/jobcontroller/service/JobControllerServiceTest.java‎
Lines changed: 4 additions & 2 deletions b/‎job-controller/src/test/java/feast/jobcontroller/service/JobControllerServiceTest.java‎
Lines changed: 4 additions & 2 deletions
@@ -65,6 +65,7 @@
 @SpringBootTest(
     properties = {
       "feast.jobs.enabled=true",
+      "feast.jobs.job_id_prefix=test-prefix",
       "feast.jobs.polling_interval_milliseconds=1000",
       "feast.stream.specsOptions.notifyIntervalMilliseconds=1000",
       "feast.jobs.controller.consolidate-jobs-per-source=true",
@@ -166,6 +167,9 @@ public void shouldCreateJobForNewSource() {
 
     assertThat(
         jobManager.getAllJobs(), containsInAnyOrder(hasProperty("id", equalTo(job.getId()))));
+    assertThat(
+        jobManager.getAllJobs(),
+        containsInAnyOrder(hasProperty("id", containsString("test-prefix"))));
   }
 
   @Test
 
@@ -76,6 +76,7 @@ public void setUp() {
     feastProperties = new FeastProperties();
     JobProperties jobProperties = new JobProperties();
     jobProperties.setJobUpdateTimeoutSeconds(5);
+    jobProperties.setJobIdPrefix("test-prefix");
 
     FeastProperties.JobProperties.ControllerProperties.FeatureSetSelector selector =
         new FeastProperties.JobProperties.ControllerProperties.FeatureSetSelector();
@@ -104,7 +105,7 @@ public void setUp() {
             specService,
             jobManager,
             feastProperties,
-            new ConsolidatedJobStrategy(jobRepository),
+            new ConsolidatedJobStrategy(jobRepository, feastProperties.getJobs()),
             mock(KafkaTemplate.class));
 
     controllerWithJobPerStore =
@@ -113,7 +114,7 @@ public void setUp() {
             specService,
             jobManager,
             feastProperties,
-            new JobPerStoreStrategy(jobRepository),
+            new JobPerStoreStrategy(jobRepository, feastProperties.getJobs()),
             mock(KafkaTemplate.class));
   }
 
@@ -286,6 +287,7 @@ public void shouldCreateJobIfNoRunning() {
         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);
   }