github/AutoGPT
1
1
Fork 0
mirror of https://github.com/Significant-Gravitas/AutoGPT.git synced 2026-04-08 03:00:28 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(backend/executor): Avoid full table scan on AgentNodeExecutionInputOutput table

Browse Source
This commit is contained in:
Zamil Majdy
2025-05-27 02:52:48 +07:00
parent 8e2fb2daa4
commit cab12992d3
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
autogpt_platform/backend/backend/data/execution.py
View File

@@ -492,15 +492,21 @@ async def upsert_execution_input(
"agentNodeId": node_id,
"agentGraphExecutionId": graph_exec_id,
"executionStatus": ExecutionStatus.INCOMPLETE,
"Input": {"every": {"name": {"not": input_name}}},
}
if node_exec_id:
existing_exec_query_filter["id"] = node_exec_id
existing_execution = await AgentNodeExecution.prisma().find_first(
where=existing_exec_query_filter,
order={"addedTime": "asc"},
include={"Input": True},
existing_execution = next(
(
execution
for execution in await AgentNodeExecution.prisma().find_many(
where=existing_exec_query_filter,
order={"addedTime": "asc"},
include={"Input": True},
)
if input_name not in [d.name for d in execution.Input or []]
),
None,
)
json_input_data = Json(input_data)