Restarting jobs in producer supervision

[nonrtric.git] / enrichment-coordinator-service / src / main / java / org / oransc / enrichment / repository / EiProducers.java

diff --git a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/repository/EiProducers.java b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/repository/EiProducers.java
index a0d30e8..f0fc49f 100644 (file)
--- a/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/repository/EiProducers.java
+++ b/enrichment-coordinator-service/src/main/java/org/oransc/enrichment/repository/EiProducers.java
@@ -85,7 +85,7 @@ public class EiProducers {
         Collection<EiType> previousTypes =
             previousDefinition != null ? previousDefinition.getEiTypes() : new ArrayList<>();
 
-        producerCallbacks.restartEiJobs(producer, this.eiJobs) //
+        producerCallbacks.startEiJobs(producer, this.eiJobs) //
             .collectList() //
             .flatMapMany(list -> consumerCallbacks.notifyJobStatus(producer.getEiTypes())) //
             .collectList() //