diff --git a/letta/services/job_manager.py b/letta/services/job_manager.py index 0e6deb71..b192afa8 100644 --- a/letta/services/job_manager.py +++ b/letta/services/job_manager.py @@ -62,8 +62,10 @@ class JobManager: pydantic_job.user_id = actor.id job_data = pydantic_job.model_dump(to_orm=True) job = JobModel(**job_data) - await job.create_async(session, actor=actor) # Save job in the database - return job.to_pydantic() + job = await job.create_async(session, actor=actor, no_commit=True, no_refresh=True) # Save job in the database + result = job.to_pydantic() + await session.commit() + return result @enforce_types @trace_method