diff --git a/src/media.js b/src/media.js
index 4f7be4f1..2f03e66c 100755
--- a/src/media.js
+++ b/src/media.js
@@ -1032,7 +1032,7 @@ async function flushOrphanedMedia(stage = 1) {
 	logger.info(`Flushing orphaned media, stage ${stage}`);
 
 	const orphanedMedia = await knex('media')
-		.select('id', 'path', 'thumbnail', 'lazy', 'is_s3')
+		.select('id', 'path', 'thumbnail', 'lazy', 'is_s3', 'source')
 		.where('is_sfw', false)
 		.whereNotExists(
 			knex.from(