Benature/omnivore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Clean up return signature

Browse Source
This commit is contained in:
Jackson Harper
2023-10-17 18:30:57 +08:00
parent d8a5ed42e8
commit fd57e075d7
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/queue-manager/src/index.ts
View File

@ -97,12 +97,12 @@ const checkShouldPauseQueues = async () => {
0
) / ts.points.length
if (avgLatency > LATENCY_THRESHOLD) {
return [true, avgLatency]
return { shouldPauseQueues: true, avgLatency: avgLatency }
}
}
}
return [false, 0]
return { shouldPauseQueues: false, avgLatency: 0 }
}
const getQueueTaskCount = async (queueName: string) => {
@ -143,7 +143,7 @@ async function checkMetricsAndPauseQueues() {
throw new Error('environment not supplied.')
}
const [shouldPauseQueues, avgLatency] = await checkShouldPauseQueues()
const { shouldPauseQueues, avgLatency } = await checkShouldPauseQueues()
if (shouldPauseQueues) {
let rssQueueCount: number | string = 'unknown'