interesting
/
PeerTube
mirror of https://github.com/Chocobozzz/PeerTube.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Don't retry UpdateVideosScheduler transactions

This commit is contained in:
Chocobozzz 2021-06-17 08:51:29 +02:00
parent 8ebf2a5d5d
commit c6406f4750
No known key found for this signature in database
GPG Key ID: 583A612D890159BE
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/lib/schedulers/update-videos-scheduler.ts
View File

@ -1,13 +1,12 @@
import { logger } from '../../helpers/logger'
import { AbstractScheduler } from './abstract-scheduler'
import { ScheduleVideoUpdateModel } from '../../models/video/schedule-video-update'
import { retryTransactionWrapper } from '../../helpers/database-utils'
import { federateVideoIfNeeded } from '../activitypub/videos'
import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
import { Notifier } from '../notifier'
import { sequelizeTypescript } from '../../initializers/database'
import { MVideoFullLight } from '@server/types/models'
import { VideoModel } from '@server/models/video/video' import { VideoModel } from '@server/models/video/video'
import { MVideoFullLight } from '@server/types/models'
import { logger } from '../../helpers/logger'
import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
import { sequelizeTypescript } from '../../initializers/database'
import { ScheduleVideoUpdateModel } from '../../models/video/schedule-video-update'
import { federateVideoIfNeeded } from '../activitypub/videos'
import { Notifier } from '../notifier'
import { AbstractScheduler } from './abstract-scheduler'
export class UpdateVideosScheduler extends AbstractScheduler { export class UpdateVideosScheduler extends AbstractScheduler {
@ -20,7 +19,7 @@ export class UpdateVideosScheduler extends AbstractScheduler {
} }
protected async internalExecute () { protected async internalExecute () {
return retryTransactionWrapper(this.updateVideos.bind(this)) return this.updateVideos()
} }
private async updateVideos () { private async updateVideos () {