asyncResource?.emitDestroy()
this.afterTaskExecutionHook(workerNodeKey, message)
queueMicrotask(() => {
- this.checkAndEmitTaskExecutionFinishedEvents()
// eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
workerNode?.emit('taskFinished', taskId)
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.promiseResponseMap.delete(taskId!)
+ this.checkAndEmitTaskExecutionFinishedEvents()
if (this.opts.enableTasksQueue === true && !this.destroying) {
if (
!this.isWorkerNodeBusy(workerNodeKey) &&