Add more logs
This commit is contained in:
parent
f76edea5f8
commit
217666c707
|
@ -20,6 +20,8 @@ async function indexChannels (channels: IndexableChannel[], replace = false) {
|
||||||
}
|
}
|
||||||
|
|
||||||
function refreshChannelsIndex () {
|
function refreshChannelsIndex () {
|
||||||
|
logger.info('Refreshing channels index.')
|
||||||
|
|
||||||
return elasticSearch.indices.refresh({ index: CONFIG.ELASTIC_SEARCH.INDEXES.CHANNELS })
|
return elasticSearch.indices.refresh({ index: CONFIG.ELASTIC_SEARCH.INDEXES.CHANNELS })
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -21,6 +21,8 @@ async function indexVideos (videos: IndexableVideo[], replace = false) {
|
||||||
}
|
}
|
||||||
|
|
||||||
function refreshVideosIndex () {
|
function refreshVideosIndex () {
|
||||||
|
logger.info('Refreshing videos index.')
|
||||||
|
|
||||||
return elasticSearch.indices.refresh({ index: CONFIG.ELASTIC_SEARCH.INDEXES.VIDEOS })
|
return elasticSearch.indices.refresh({ index: CONFIG.ELASTIC_SEARCH.INDEXES.VIDEOS })
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -87,6 +87,8 @@ export class VideosIndexer extends AbstractScheduler {
|
||||||
|
|
||||||
await refreshChannelsIndex()
|
await refreshChannelsIndex()
|
||||||
await refreshVideosIndex()
|
await refreshVideosIndex()
|
||||||
|
|
||||||
|
logger.info('Videos indexer ended.')
|
||||||
}
|
}
|
||||||
|
|
||||||
private async indexHost (host: string) {
|
private async indexHost (host: string) {
|
||||||
|
|
Loading…
Reference in New Issue