first commit

src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessingImpl.scala

     tvSerieIdFuture.andThen({
       case Failure(exception) => logger.error(s"${exception.printStackTrace()}")
       case Success(value: Option[String]) =>
-        logger.info(s"${value.get}")
+        logger.info(s"TvSerie ID${value.get}")
         logger.info(s"STEP 1/3 END, elapsed time:${(System.currentTimeMillis() - start1) / 1000} sec")
 
     })

src/main/scala/fr/natan/akkastreamfileprocessingapi/service/UtilitiesClass.scala

 import akka.NotUsed
 import akka.stream.scaladsl.{Flow, Sink, Source}
 import com.typesafe.scalalogging.slf4j.Logger
-import fr.natan.akkastreamfileprocessingapi.businessexceptions.TvSerieNotFoundException
 import fr.natan.akkastreamfileprocessingapi.models.ModelsAndJsonMap.Person
 import fr.natan.akkastreamfileprocessingapi.models.ModelsBuilder.buildPersonModel
 import fr.natan.akkastreamfileprocessingapi.service.AkkaStreamComponents.{actorSystem, buildAndValidateSource}
 
 import java.io.File
-import scala.concurrent.ExecutionContext.Implicits.global
 import scala.concurrent.Future
-import scala.util.{Failure, Success}
 
 object UtilitiesClass {
 
       .map(row => row.get("tconst"))
       .runWith(Sink.head)
 
-    tvSerieIdFuture.onComplete({
-      case Failure(noSuchElementException: NoSuchElementException) => throw new TvSerieNotFoundException()
-      case Failure(exception: Exception) => throw new RuntimeException()
-      case Success(value) => logger.info(s"$value")
-    })
-
     tvSerieIdFuture
   }