Peter Mutwiri commited on
Commit ·
dd32be5
1
Parent(s): c98fee1
resolved orgid import
Browse files- app/routers/schema.py +3 -3
app/routers/schema.py
CHANGED
|
@@ -2,7 +2,7 @@
|
|
| 2 |
from fastapi import APIRouter, Depends
|
| 3 |
from app.deps import get_current_user
|
| 4 |
from typing import Dict
|
| 5 |
-
from app.schemas import
|
| 6 |
router = APIRouter(prefix="/api/v1/schema", tags=["schema"])
|
| 7 |
|
| 8 |
@router.get("/discover")
|
|
@@ -11,7 +11,7 @@ async def discover_schema(
|
|
| 11 |
):
|
| 12 |
org_id = current_user["org_id"]
|
| 13 |
"""Return column mappings for this org"""
|
| 14 |
-
schema =
|
| 15 |
return schema.get_mapping()
|
| 16 |
|
| 17 |
@router.post("/override")
|
|
@@ -22,6 +22,6 @@ async def override_schema(
|
|
| 22 |
org_id = current_user["org_id"] # Then extract inside function
|
| 23 |
|
| 24 |
"""Allow manual column mapping override"""
|
| 25 |
-
schema =
|
| 26 |
schema.save_mapping(mapping)
|
| 27 |
return {"status": "saved", "mapping": mapping}
|
|
|
|
| 2 |
from fastapi import APIRouter, Depends
|
| 3 |
from app.deps import get_current_user
|
| 4 |
from typing import Dict
|
| 5 |
+
from app.schemas.org_schema import OrgSchema
|
| 6 |
router = APIRouter(prefix="/api/v1/schema", tags=["schema"])
|
| 7 |
|
| 8 |
@router.get("/discover")
|
|
|
|
| 11 |
):
|
| 12 |
org_id = current_user["org_id"]
|
| 13 |
"""Return column mappings for this org"""
|
| 14 |
+
schema = OrgSchema(org_id)
|
| 15 |
return schema.get_mapping()
|
| 16 |
|
| 17 |
@router.post("/override")
|
|
|
|
| 22 |
org_id = current_user["org_id"] # Then extract inside function
|
| 23 |
|
| 24 |
"""Allow manual column mapping override"""
|
| 25 |
+
schema = OrgSchema(org_id)
|
| 26 |
schema.save_mapping(mapping)
|
| 27 |
return {"status": "saved", "mapping": mapping}
|