diff --git a/processor/src/queues.ts b/processor/src/queues.ts index e88b3d56bc..2125c1b2b3 100644 --- a/processor/src/queues.ts +++ b/processor/src/queues.ts @@ -182,7 +182,7 @@ const lock = new AsyncLock() async function sync(gitDir, checkoutDir) { await lock .acquire(gitDir, async () => { - log.info('Acquired sync lock for ', gitDir) + log.info('Acquired lock for ', gitDir) const registryHash = getRegistryHash(gitDir) @@ -225,7 +225,8 @@ async function sync(gitDir, checkoutDir) { } } }) - .then(() => log.debug('Released sync lock for ', gitDir)) + .then(() => log.debug('Released lock for ', gitDir)) + .catch(e => log.warn('Released lock for', gitDir, 'after error:', e)) } /**