|
|
@ -120,8 +120,12 @@ export class InitMigrationJobs { |
|
|
|
// clear stall interval
|
|
|
|
// clear stall interval
|
|
|
|
clearInterval(stallInterval); |
|
|
|
clearInterval(stallInterval); |
|
|
|
|
|
|
|
|
|
|
|
// run the job again
|
|
|
|
// run the job again if successful
|
|
|
|
await this.jobsService.add(MigrationJobTypes.InitMigrationJobs, {}); |
|
|
|
if (migrated) { |
|
|
|
|
|
|
|
await this.jobsService.add(MigrationJobTypes.InitMigrationJobs, {}); |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
this.log('A migration job failed!'); |
|
|
|
|
|
|
|
} |
|
|
|
} catch (e) { |
|
|
|
} catch (e) { |
|
|
|
this.log('Error running migration: ', e); |
|
|
|
this.log('Error running migration: ', e); |
|
|
|
} |
|
|
|
} |
|
|
|