Untitled

from fastapi import APIRouter, Depends
from routes import fastapi_users
from models import User

router = APIRouter()
fastapi_users = await fastapi_users()


@router.post("/endpoint_1")
async def fetch_to_pipeline_handler(user: User = Depends(fastapi_users.current_user(active=True))):
    .......

@router.get("/endpoint_2")
async def fetch_pipeline_items(user: model.User = Depends(fastapi_users.current_user(active=True))):
    ........


@router.patch("/endpoint_3")
async def fetch_pipeline_items(user: model.User = Depends(fastapi_users.current_user(active=True))):
    ........