X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=enrichment-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fenrichment%2Frepository%2FEiProducers.java;h=f0fc49ff531eafc2348912665ee8282fad09884c;hb=2dbde318f013212c81c4a1f477d7638ec3367aa5;hp=a0d30e8be690150f2f2e47962000244bc15e7e43;hpb=10e254d9b7bc522bb2c25d590e6d203bf25a592d;p=nonrtric.git 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 a0d30e8b..f0fc49ff 100644 --- 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 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() //