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

fix: avoid holding sessions open (#6769)

Browse Source
This commit is contained in:
Sarah Wooders
2025-12-11 19:59:26 -08:00
committed by Caren Thomas
parent c9ad2fd7c4
commit 0634aa13a1
1 changed files with 12 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
letta/services/step_manager.py
View File

@@ -363,12 +363,10 @@ class StepManager:
await session.commit()
pydantic_step = step.to_pydantic()
# Send webhook notification for step completion
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
# Send webhook notification for step completion outside the DB session
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
@enforce_types
@trace_method
@@ -416,12 +414,10 @@ class StepManager:
await session.commit()
pydantic_step = step.to_pydantic()
# Send webhook notification for step completion
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
# Send webhook notification for step completion outside the DB session
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
@enforce_types
@trace_method
@@ -458,12 +454,10 @@ class StepManager:
await session.commit()
pydantic_step = step.to_pydantic()
# Send webhook notification for step completion
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
# Send webhook notification for step completion outside the DB session
webhook_service = WebhookService()
await webhook_service.notify_step_complete(step_id)
return pydantic_step
@enforce_types
@trace_method