Leopoldadmin/leocrm
1
0
Fork 0
Code Issues 363 Pull Requests Actions 1 Packages Projects Releases 1 Wiki Activity

fix(ai-assistant): Alle create_* Routes flush vor refresh statt commit
Check Cross-Plugin Imports / check (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Agent Zero
2026-08-21 18:55:01 +02:00
parent 33162b5283
commit 37f6868328
1 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/plugins/builtins/ai_assistant/routes.py
+16 -8
View File
@@ -126,8 +126,9 @@ async def update_provider(
for field, val in data.model_dump(exclude_unset=True).items(): for field, val in data.model_dump(exclude_unset=True).items():
setattr(provider, field, val) setattr(provider, field, val)
await db.commit() await db.flush()
await db.refresh(provider) await db.refresh(provider)
await db.commit()
return provider_to_response(provider) return provider_to_response(provider)
@@ -209,8 +210,9 @@ async def update_model(
for field, val in data.model_dump(exclude_unset=True).items(): for field, val in data.model_dump(exclude_unset=True).items():
setattr(model, field, val) setattr(model, field, val)
await db.commit() await db.flush()
await db.refresh(model) await db.refresh(model)
await db.commit()
return model_to_response(model) return model_to_response(model)
@@ -271,8 +273,9 @@ async def create_preset(
tenant_id=tenant_id, tenant_id=tenant_id,
) )
db.add(preset) db.add(preset)
await db.commit() await db.flush()
await db.refresh(preset) await db.refresh(preset)
await db.commit()
return preset_to_response(preset) return preset_to_response(preset)
@@ -293,8 +296,9 @@ async def update_preset(
update_data["provider_id"] = uuid.UUID(update_data["provider_id"]) update_data["provider_id"] = uuid.UUID(update_data["provider_id"])
for field, val in update_data.items(): for field, val in update_data.items():
setattr(preset, field, val) setattr(preset, field, val)
await db.commit() await db.flush()
await db.refresh(preset) await db.refresh(preset)
await db.commit()
return preset_to_response(preset) return preset_to_response(preset)
@@ -354,8 +358,9 @@ async def create_agent(
owner_id=user_id, owner_id=user_id,
) )
db.add(agent) db.add(agent)
await db.commit() await db.flush()
await db.refresh(agent) await db.refresh(agent)
await db.commit()
return agent_to_response(agent) return agent_to_response(agent)
@@ -376,8 +381,9 @@ async def update_agent(
update_data["preset_id"] = uuid.UUID(update_data["preset_id"]) update_data["preset_id"] = uuid.UUID(update_data["preset_id"])
for field, val in update_data.items(): for field, val in update_data.items():
setattr(agent, field, val) setattr(agent, field, val)
await db.commit() await db.flush()
await db.refresh(agent) await db.refresh(agent)
await db.commit()
return agent_to_response(agent) return agent_to_response(agent)
@@ -445,8 +451,9 @@ async def create_folder(
tenant_id=tenant_id, tenant_id=tenant_id,
) )
db.add(folder) db.add(folder)
await db.commit() await db.flush()
await db.refresh(folder) await db.refresh(folder)
await db.commit()
return folder_to_response(folder) return folder_to_response(folder)
@@ -477,8 +484,9 @@ async def update_folder(
update_data["parent_id"] = None update_data["parent_id"] = None
for field, val in update_data.items(): for field, val in update_data.items():
setattr(folder, field, val) setattr(folder, field, val)
await db.commit() await db.flush()
await db.refresh(folder) await db.refresh(folder)
await db.commit()
return folder_to_response(folder) return folder_to_response(folder)