rsync: throw on del error

This commit is contained in:
Girish Ramakrishnan
2025-07-14 21:57:20 +02:00
parent 27c5721e2b
commit 8b5fe714e1

View File

@@ -114,6 +114,7 @@ async function sync(backupConfig, remotePath, dataLayout, progressCallback) {
const [delError] = await safe(async.eachLimit(changes.delQueue, concurrency, async (change) => await processSyncerChange(change, backupConfig, remotePath, dataLayout, progressCallback)));
debug('sync: done processing deletes. error: %o', delError);
if (delError) throw delError;
const [addError] = await safe(async.eachLimit(changes.addQueue, concurrency, async (change) => await processSyncerChange(change, backupConfig, remotePath, dataLayout, progressCallback)));
debug('sync: done processing adds. error: %o', addError);