Fimeg/letta-server
1
0
Fork 0
Code Issues 4 Pull Requests Actions 3 Packages Projects Releases Wiki Activity

feat: use no refresh in job update (#3421)

Browse Source
This commit is contained in:
cthomas
2025-07-19 21:33:08 -07:00
committed by GitHub
parent cadc040f42
commit bb1a51a0a3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
letta/services/job_manager.py
View File

@@ -174,11 +174,12 @@ class JobManager:
job.completed_at = get_utc_time().replace(tzinfo=None)
# Save the updated job to the database first
job = await job.update_async(db_session=session, actor=actor)
job = await job.update_async(db_session=session, actor=actor, no_commit=True, no_refresh=True)
# Get the updated metadata for callback
final_metadata = job.metadata_
result = job.to_pydantic()
await session.commit()
# Dispatch callback outside of database session if needed
if needs_callback:
@@ -197,8 +198,9 @@ class JobManager:
job.callback_sent_at = callback_result["callback_sent_at"]
job.callback_status_code = callback_result.get("callback_status_code")
job.callback_error = callback_result.get("callback_error")
await job.update_async(db_session=session, actor=actor)
await job.update_async(db_session=session, actor=actor, no_commit=True, no_refresh=True)
result = job.to_pydantic()
await session.commit()
return result