prefect.concurrency.services

Classes

ConcurrencySlotAcquisitionService

Methods:

acquire

acquire(self, slots: int, mode: Literal['concurrency', 'rate_limit'], timeout_seconds: Optional[float] = None, max_retries: Optional[int] = None) -> httpx.Response