+ const tasksQueueSize = this.workerNodes[workerNodeKey].enqueueTask(task)
+ if (this.hasWorkerNodeBackPressure(workerNodeKey)) {
+ this.emitter?.emit(PoolEvents.backPressure, {
+ workerId: this.getWorkerInfo(workerNodeKey).id,
+ ...this.info
+ })
+ }
+ return tasksQueueSize