}
private initTaskFunctionWorkerUsage (name: string): WorkerUsage {
- const getTaskQueueSize = (): number => {
- let taskQueueSize = 0
+ const getTaskFunctionQueueSize = (): number => {
+ let taskFunctionQueueSize = 0
for (const task of this.tasksQueue) {
- if (task.name === name) {
- ++taskQueueSize
+ if (
+ (task.name === DEFAULT_TASK_NAME &&
+ name === (this.info.taskFunctions as string[])[1]) ||
+ (task.name !== DEFAULT_TASK_NAME && name === task.name)
+ ) {
+ ++taskFunctionQueueSize
}
}
- return taskQueueSize
+ return taskFunctionQueueSize
}
return {
tasks: {
executed: 0,
executing: 0,
get queued (): number {
- return getTaskQueueSize()
+ return getTaskFunctionQueueSize()
},
failed: 0
},