run chain controller (undone)
This commit is contained in:
parent
83acdfdc89
commit
f1cfa85843
|
|
@ -1,8 +1,13 @@
|
||||||
from fastapi import FastAPI, APIRouter
|
|
||||||
from .chain import router as chain_router
|
from .chain import router as chain_router
|
||||||
|
from .run_chain import router as run_chain_router
|
||||||
|
|
||||||
|
from fastapi import FastAPI, APIRouter
|
||||||
|
|
||||||
|
|
||||||
def setup_controllers(application: FastAPI):
|
def setup_controllers(application: FastAPI):
|
||||||
router = APIRouter(prefix="/api")
|
router = APIRouter(prefix="/api")
|
||||||
|
|
||||||
router.include_router(chain_router)
|
router.include_router(chain_router)
|
||||||
|
router.include_router(run_chain_router)
|
||||||
|
|
||||||
application.include_router(router)
|
application.include_router(router)
|
||||||
|
|
|
||||||
15
chain_service/controllers/run_chain.py
Normal file
15
chain_service/controllers/run_chain.py
Normal file
|
|
@ -0,0 +1,15 @@
|
||||||
|
from loguru import logger
|
||||||
|
from fastapi import APIRouter, HTTPException
|
||||||
|
|
||||||
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
@router.post("/run_chain")
|
||||||
|
async def run_chain_controller():
|
||||||
|
try:
|
||||||
|
logger.info("Got chain to run")
|
||||||
|
return {"works": True}
|
||||||
|
|
||||||
|
except Exception:
|
||||||
|
logger.exception("Error during run chain")
|
||||||
|
return HTTPException(status_code=500, detail="Error during run chain")
|
||||||
Loading…
Reference in New Issue
Block a user