aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2018-10-02 09:04:19 +0200
committerChocobozzz <me@florianbigard.com>2018-10-02 09:04:19 +0200
commit792e5b8e5b731e15228dd5938bc2f99bb2e1070a (patch)
treed9290b11aea35934f653cb38fb1b3bf948b8a575 /server/lib
parent913f08f2bd5b03c121ee65751e938e4faa27e7f1 (diff)
downloadPeerTube-792e5b8e5b731e15228dd5938bc2f99bb2e1070a.tar.gz
PeerTube-792e5b8e5b731e15228dd5938bc2f99bb2e1070a.tar.zst
PeerTube-792e5b8e5b731e15228dd5938bc2f99bb2e1070a.zip
Try to improve redundancy tests
Diffstat (limited to 'server/lib')
-rw-r--r--server/lib/activitypub/videos.ts2
-rw-r--r--server/lib/schedulers/videos-redundancy-scheduler.ts2
2 files changed, 4 insertions, 0 deletions
diff --git a/server/lib/activitypub/videos.ts b/server/lib/activitypub/videos.ts
index cd1bc4e06..54cea542f 100644
--- a/server/lib/activitypub/videos.ts
+++ b/server/lib/activitypub/videos.ts
@@ -396,6 +396,8 @@ async function refreshVideoIfNeeded (options: {
396 } 396 }
397 await retryTransactionWrapper(updateVideoFromAP, updateOptions) 397 await retryTransactionWrapper(updateVideoFromAP, updateOptions)
398 await syncVideoExternalAttributes(video, videoObject, options.syncParam) 398 await syncVideoExternalAttributes(video, videoObject, options.syncParam)
399
400 return video
399 } catch (err) { 401 } catch (err) {
400 logger.warn('Cannot refresh video %s.', options.video.url, { err }) 402 logger.warn('Cannot refresh video %s.', options.video.url, { err })
401 return video 403 return video
diff --git a/server/lib/schedulers/videos-redundancy-scheduler.ts b/server/lib/schedulers/videos-redundancy-scheduler.ts
index 0b1ae76ff..607bdf67c 100644
--- a/server/lib/schedulers/videos-redundancy-scheduler.ts
+++ b/server/lib/schedulers/videos-redundancy-scheduler.ts
@@ -157,6 +157,8 @@ export class VideosRedundancyScheduler extends AbstractScheduler {
157 createdModel.VideoFile = file 157 createdModel.VideoFile = file
158 158
159 await sendCreateCacheFile(serverActor, createdModel) 159 await sendCreateCacheFile(serverActor, createdModel)
160
161 logger.info('Duplicated %s - %d -> %s.', video.url, file.resolution, createdModel.url)
160 } 162 }
161 } 163 }
162 164