(ownerKey: string)
| 495 | } |
| 496 | |
| 497 | function maybeCleanupOwner(ownerKey: string) { |
| 498 | const owner = ownerStates.get(ownerKey) |
| 499 | if (!owner) return |
| 500 | if (owner.queueLength === 0) { |
| 501 | removeOwnerFromRing(ownerKey) |
| 502 | } |
| 503 | if (owner.queueLength === 0 && owner.activeExecutions === 0) { |
| 504 | ownerStates.delete(ownerKey) |
| 505 | } |
| 506 | } |
| 507 | |
| 508 | function removeQueueNode(node: QueueNode): QueuedExecution { |
| 509 | const owner = ownerStates.get(node.ownerKey) |
no test coverage detected