Release the semaphore :param tag: A tag identifying what is releasing the semaphore :param acquire_token: The token returned from when the semaphore was acquired. Note that this is not really needed to directly use this class but is needed for API compatibil
(self, tag, acquire_token)
| 639 | raise NoResourcesAvailable(f"Cannot acquire tag '{tag}'") |
| 640 | |
| 641 | def release(self, tag, acquire_token): |
| 642 | """Release the semaphore |
| 643 | |
| 644 | :param tag: A tag identifying what is releasing the semaphore |
| 645 | :param acquire_token: The token returned from when the semaphore was |
| 646 | acquired. Note that this is not really needed to directly use this |
| 647 | class but is needed for API compatibility with the |
| 648 | SlidingWindowSemaphore implementation. |
| 649 | """ |
| 650 | logger.debug(f"Releasing acquire {tag}/{acquire_token}") |
| 651 | self._semaphore.release() |
| 652 | |
| 653 | |
| 654 | class SlidingWindowSemaphore(TaskSemaphore): |
no outgoing calls