diff --git a/src/media.js b/src/media.js index dbbcac6e..8d6dd14a 100755 --- a/src/media.js +++ b/src/media.js @@ -1022,7 +1022,7 @@ async function deleteS3Objects(allMedia) { const status = await s3.send(deleteCommand); - logger.info(`Removed ${status.Deleted.length} media files from S3 bucket '${config.s3.bucket}', ${status.Errors.length} errors`); + logger.info(`Removed ${status.Deleted.length} media files from S3 bucket '${config.s3.bucket}', ${status.Errors?.length || 0} errors`); return acc.concat(status); }, Promise.resolve()).catch((error) => { @@ -1065,8 +1065,7 @@ async function flushOrphanedMedia(stage = 1) { ) .whereRaw('associations.media_id = media.id'), ) - // .limit(config.media.flushWindow); - .limit(1); + .limit(config.media.flushWindow); // .delete(); logger.info(`Found ${orphanedMedia.length} orphaned media entries in stage ${stage}`);