diff --git a/src/prefect/server/models/concurrency_limits_v2.py b/src/prefect/server/models/concurrency_limits_v2.py index 64b53f7a8fe1..077c8321cdb7 100644 --- a/src/prefect/server/models/concurrency_limits_v2.py +++ b/src/prefect/server/models/concurrency_limits_v2.py @@ -185,32 +185,6 @@ async def delete_concurrency_limit( return result.rowcount > 0 -async def create_or_update_concurrency_limit( - session: AsyncSession, - concurrency_limit: Union[ - schemas.actions.ConcurrencyLimitV2Create, schemas.core.ConcurrencyLimitV2 - ], - concurrency_limit_id: Optional[UUID] = None, - name: Optional[str] = None, -) -> orm_models.ConcurrencyLimitV2: - if not concurrency_limit_id and not name: - raise ValueError("Must provide either concurrency_limit_id or name") - - current_concurrency_limit = await read_concurrency_limit( - session, concurrency_limit_id=concurrency_limit_id, name=name - ) - - if not current_concurrency_limit: - return await create_concurrency_limit(session, concurrency_limit) - else: - return await update_concurrency_limit( - session, - concurrency_limit, - concurrency_limit_id=concurrency_limit_id, - name=name, - ) - - async def bulk_read_or_create_concurrency_limits( session: AsyncSession, names: List[str],