tbelway/immich-quadlet
1
0
Fork 0
forked from Cutlery/immich
Code Pull Requests Activity

decrease batch size to 1000

Browse Source
This commit is contained in:
Jonathan Jogenfors 2024-03-20 11:45:09 +01:00
parent ea47cb84a4
commit 5cdf31c739
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/src/domain/library/library.service.ts
View File

@ -50,7 +50,7 @@ import {
mapLibrary, mapLibrary,
} from './library.dto'; } from './library.dto';
const LIBRARY_SCAN_BATCH_SIZE = 5000; const LIBRARY_SCAN_BATCH_SIZE = 1000;
@Injectable() @Injectable()
export class LibraryService extends EventEmitter { export class LibraryService extends EventEmitter {
@ -656,7 +656,7 @@ export class LibraryService extends EventEmitter {
exclusionPatterns: library.exclusionPatterns, exclusionPatterns: library.exclusionPatterns,
}); });
const existingAssets = usePagination(LIBRARY_SCAN_BATCH_SIZE, (pagination) => const onlineAssets = usePagination(LIBRARY_SCAN_BATCH_SIZE, (pagination) =>
this.assetRepository.getWith(pagination, WithProperty.IS_ONLINE, job.id), this.assetRepository.getWith(pagination, WithProperty.IS_ONLINE, job.id),
); );
@ -665,8 +665,8 @@ export class LibraryService extends EventEmitter {
let crawlCounter = 0; let crawlCounter = 0;
let existingAssetCounter = 0; let existingAssetCounter = 0;
const checkNextAssetPageForOffline = async () => { const checkIfOnlineAssetsAreOffline = async () => {
const existingAssetPage = await existingAssets.next(); const existingAssetPage = await onlineAssets.next();
existingAssetsDone = existingAssetPage.done ?? true; existingAssetsDone = existingAssetPage.done ?? true;
if (existingAssetPage.value) { if (existingAssetPage.value) {
@ -703,14 +703,14 @@ export class LibraryService extends EventEmitter {
if (!existingAssetsDone) { if (!existingAssetsDone) {
// Interweave the queuing of offline checks with the asset scanning (if any) // Interweave the queuing of offline checks with the asset scanning (if any)
await checkNextAssetPageForOffline(); await checkIfOnlineAssetsAreOffline();
} }
} }
} }
// If there are any remaining assets to check for offline status, do so // If there are any remaining assets to check for offline status, do so
while (!existingAssetsDone) { while (!existingAssetsDone) {
await checkNextAssetPageForOffline(); await checkIfOnlineAssetsAreOffline();
} }
this.logger.log( this.logger.log(