Function delete_cluster

gpustack/routes/clusters.py:590–621

(session: SessionDep, ctx: TenantContextDep, id: int)

@router.delete("/{id}")
async def delete_cluster(session: SessionDep, ctx: TenantContextDep, id: int):
    existing = await Cluster.one_by_id(
        session,
        id,
        options=[
            selectinload(Cluster.cluster_workers),
            selectinload(Cluster.cluster_models),
            selectinload(Cluster.cluster_model_instances),
        ],
    )
    if not existing or existing.deleted_at is not None:
        raise NotFoundException(message=f"cluster {id} not found")
    assert_cluster_writable(ctx, existing)
    # check for workers, if any are present, prevent deletion
    if len(existing.cluster_workers) > 0:
        raise ConflictException(
            message=f"cluster {existing.name}(id: {id}) has workers, cannot be deleted"
        )
    # check for models, if any are present, prevent deletion
    if len(existing.cluster_models) > 0:
        raise ConflictException(
            message=f"cluster {existing.name}(id: {id}) has models, cannot be deleted"
        )
    # check for model instances, if any are present, prevent deletion
    if len(existing.cluster_model_instances) > 0:
        raise ConflictException(
            message=f"cluster {existing.name}(id: {id}) has model instances, cannot be deleted"
        )
    try:
        await existing.delete(session=session)
    except Exception as e:
        raise InternalServerErrorException(message=f"Failed to delete cluster: {e}")


@router.post("/{id}/set-default")