diff --git a/src/Utils/make-mutex.ts b/src/Utils/make-mutex.ts index a632caa..8bb9f54 100644 --- a/src/Utils/make-mutex.ts +++ b/src/Utils/make-mutex.ts @@ -1,7 +1,3 @@ -import logger from './logger' - -const MUTEX_TIMEOUT_MS = 60_000 - export const makeMutex = () => { let task = Promise.resolve() as Promise @@ -10,11 +6,6 @@ export const makeMutex = () => { return { mutex(code: () => Promise | T): Promise { task = (async() => { - const stack = new Error('mutex start').stack - let waitOver = false - taskTimeout = setTimeout(() => { - logger.warn({ stack, waitOver }, 'possible mutex deadlock') - }, MUTEX_TIMEOUT_MS) // wait for the previous task to complete // if there is an error, we swallow so as to not block the queue try { @@ -50,4 +41,4 @@ export const makeKeyedMutex = () => { return map[key].mutex(task) } } -} +} \ No newline at end of file