Compare commits

...

4 Commits

Author SHA1 Message Date
Nicholas Tindle
d5b8e2dae0 Merge branch 'dev' into abhi/fix-get-agent-db-function 2025-03-06 11:28:09 -06:00
abhi1992002
0be6ff45c7 fix lint 2025-01-28 11:12:28 +05:30
abhi1992002
c8b17c6d03 remove user_id from graph_data in download_agent_file route 2025-01-28 11:05:18 +05:30
abhi1992002
5a13db8054 remove raises and delattr on get agent db function 2025-01-28 10:44:50 +05:30
2 changed files with 12 additions and 14 deletions

View File

@@ -2,7 +2,6 @@ import logging
from datetime import datetime
from typing import Optional
import fastapi
import prisma.enums
import prisma.errors
import prisma.models
@@ -755,7 +754,7 @@ async def get_my_agents(
async def get_agent(
store_listing_version_id: str, version_id: Optional[int]
) -> GraphModel:
) -> Optional[GraphModel]:
"""Get agent using the version ID and store listing version ID."""
try:
store_listing_version = (
@@ -765,28 +764,20 @@ async def get_agent(
)
if not store_listing_version or not store_listing_version.Agent:
raise fastapi.HTTPException(
status_code=404,
detail=f"Store listing version {store_listing_version_id} not found",
)
logger.error(f"Store listing version {store_listing_version_id} not found")
return None
graph_id = store_listing_version.agentId
graph_version = store_listing_version.agentVersion
graph = await backend.data.graph.get_graph(graph_id, graph_version)
if not graph:
raise fastapi.HTTPException(
status_code=404,
detail=(
f"Agent #{graph_id} not found "
f"for store listing version #{store_listing_version_id}"
),
)
logger.error(f"Agent {agent.id} not found")
return None
graph.version = 1
graph.is_template = False
graph.is_active = True
delattr(graph, "user_id")
return graph

View File

@@ -616,6 +616,11 @@ async def download_agent_file(
store_listing_version_id=store_listing_version_id, version_id=version
)
if not graph_data:
raise fastapi.HTTPException(
status_code=404, detail=f"Graph with {store_listing_version_id} no found"
)
graph_data.clean_graph()
graph_date_dict = jsonable_encoder(graph_data)
@@ -625,6 +630,8 @@ async def download_agent_file(
del obj["credentials"]
if "creds" in obj:
del obj["creds"]
if "user_id" in obj:
del obj["user_id"]
for value in obj.values():
remove_credentials(value)