> ## Documentation Index > Fetch the complete documentation index at: https://docs.prefect.io/llms.txt > Use this file to discover all available pages before exploring further. # concurrency_limits_v2 # `prefect.server.models.concurrency_limits_v2` ## Functions ### `emit_concurrency_limit_v2_created_event` ```python theme={null} emit_concurrency_limit_v2_created_event(concurrency_limit: orm_models.ConcurrencyLimitV2) -> None ``` Emit an event when a global concurrency limit is created. ### `emit_concurrency_limit_v2_updated_event` ```python theme={null} emit_concurrency_limit_v2_updated_event(concurrency_limit: orm_models.ConcurrencyLimitV2) -> None ``` Emit an event when a global concurrency limit is updated. ### `emit_concurrency_limit_v2_deleted_event` ```python theme={null} emit_concurrency_limit_v2_deleted_event(concurrency_limit: orm_models.ConcurrencyLimitV2) -> None ``` Emit an event when a global concurrency limit is deleted. ### `active_slots_after_decay` ```python theme={null} active_slots_after_decay(db: PrefectDBInterface) -> ColumnElement[float] ``` ### `denied_slots_after_decay` ```python theme={null} denied_slots_after_decay(db: PrefectDBInterface) -> ColumnElement[float] ``` Calculate denied\_slots after applying decay. Denied slots decay at a rate of `slot_decay_per_second` per second if it's greater than 0 (rate limits), otherwise for concurrency limits it decays at a rate based on clamped `avg_slot_occupancy_seconds`. The clamping matches the retry-after calculation to prevent denied\_slots from accumulating when clients retry faster than the unclamped decay rate. ### `create_concurrency_limit` ```python theme={null} create_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit: Union[schemas.actions.ConcurrencyLimitV2Create, schemas.core.ConcurrencyLimitV2]) -> orm_models.ConcurrencyLimitV2 ``` ### `read_concurrency_limit` ```python theme={null} read_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_id: Optional[UUID] = None, name: Optional[str] = None) -> Union[orm_models.ConcurrencyLimitV2, None] ``` ### `read_all_concurrency_limits` ```python theme={null} read_all_concurrency_limits(db: PrefectDBInterface, session: AsyncSession, limit: int, offset: int) -> Sequence[orm_models.ConcurrencyLimitV2] ``` ### `update_concurrency_limit` ```python theme={null} update_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit: schemas.actions.ConcurrencyLimitV2Update, concurrency_limit_id: Optional[UUID] = None, name: Optional[str] = None) -> bool ``` ### `delete_concurrency_limit` ```python theme={null} delete_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_id: Optional[UUID] = None, name: Optional[str] = None) -> bool ``` ### `bulk_read_concurrency_limits` ```python theme={null} bulk_read_concurrency_limits(db: PrefectDBInterface, session: AsyncSession, names: List[str]) -> List[orm_models.ConcurrencyLimitV2] ``` ### `bulk_increment_active_slots` ```python theme={null} bulk_increment_active_slots(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_ids: List[UUID], slots: int) -> bool ``` ### `bulk_decrement_active_slots` ```python theme={null} bulk_decrement_active_slots(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_ids: List[UUID], slots: int, occupancy_seconds: Optional[float] = None) -> bool ``` ### `bulk_update_denied_slots` ```python theme={null} bulk_update_denied_slots(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_ids: List[UUID], slots: int) -> bool ```