Corrected out path..
This commit is contained in:
parent
5a831dab19
commit
6c253e4349
@ -66,6 +66,7 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
val videoFileNameWithExtension = File(encodeWork.outFile).name
|
val videoFileNameWithExtension = File(encodeWork.outFile).name
|
||||||
|
val outDir = File(encodeWork.outFile).parentFile
|
||||||
|
|
||||||
val iid = transaction {
|
val iid = transaction {
|
||||||
if (serieData != null) {
|
if (serieData != null) {
|
||||||
@ -88,7 +89,7 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
|
|||||||
logger.info { "Downloading Cover: $coverUrl" }
|
logger.info { "Downloading Cover: $coverUrl" }
|
||||||
runBlocking {
|
runBlocking {
|
||||||
try {
|
try {
|
||||||
val _file = Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download()
|
val _file = Downloader(coverUrl, outDir, fileData.title).download()
|
||||||
if (_file == null || !_file.exists()) {
|
if (_file == null || !_file.exists()) {
|
||||||
logger.info { "Failed to download the file" }
|
logger.info { "Failed to download the file" }
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user