`prefect.server.models.concurrency_limits_v2`

Functions

`emit_concurrency_limit_v2_created_event`

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`

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`

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`

active_slots_after_decay(db: PrefectDBInterface) -> ColumnElement[float]

`denied_slots_after_decay`

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`

create_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit: Union[schemas.actions.ConcurrencyLimitV2Create, schemas.core.ConcurrencyLimitV2]) -> orm_models.ConcurrencyLimitV2

`read_concurrency_limit`

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`

read_all_concurrency_limits(db: PrefectDBInterface, session: AsyncSession, limit: int, offset: int) -> Sequence[orm_models.ConcurrencyLimitV2]

`update_concurrency_limit`

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`

delete_concurrency_limit(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_id: Optional[UUID] = None, name: Optional[str] = None) -> bool

`bulk_read_concurrency_limits`

bulk_read_concurrency_limits(db: PrefectDBInterface, session: AsyncSession, names: List[str]) -> List[orm_models.ConcurrencyLimitV2]

`bulk_increment_active_slots`

bulk_increment_active_slots(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_ids: List[UUID], slots: int) -> bool

`bulk_decrement_active_slots`

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`

bulk_update_denied_slots(db: PrefectDBInterface, session: AsyncSession, concurrency_limit_ids: List[UUID], slots: int) -> bool

​prefect.server.models.concurrency_limits_v2

​Functions

​emit_concurrency_limit_v2_created_event

​emit_concurrency_limit_v2_updated_event

​emit_concurrency_limit_v2_deleted_event

​active_slots_after_decay

​denied_slots_after_decay

​create_concurrency_limit

​read_concurrency_limit

​read_all_concurrency_limits

​update_concurrency_limit

​delete_concurrency_limit

​bulk_read_concurrency_limits

​bulk_increment_active_slots

​bulk_decrement_active_slots

​bulk_update_denied_slots