File tree Expand file tree Collapse file tree 3 files changed +5
-0
lines changed
Expand file tree Collapse file tree 3 files changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -648,6 +648,8 @@ class MemoryRunStore implements TriggerChatRunStore {
648648
649649` reconnectToStream() ` only resumes active streams. When a stream completes or errors,
650650the transport clears stored run state and future reconnect attempts return ` null ` .
651+ If stale inactive reconnect state cannot be cleaned up, reconnect still returns ` null ` and
652+ the failure is surfaced through ` onError ` with phase ` reconnect ` .
651653
652654For richer TypeScript ergonomics in app code, ` @trigger.dev/ai ` also exports:
653655
Original file line number Diff line number Diff line change 1717- Added normalization of non-Error throw values into Error instances before ` onError ` reporting.
1818- Added best-effort run-store cleanup so cleanup failures do not mask root transport errors.
1919- Improved best-effort run-store cleanup to attempt both inactive-state writes and deletes even if one step fails.
20+ - Added reconnect cleanup error reporting for stale inactive state while still returning ` null ` .
Original file line number Diff line number Diff line change @@ -148,6 +148,8 @@ both cleanup steps (`set` inactive state and `delete`) even if one of them fails
148148
149149- ` reconnectToStream({ chatId }) ` resumes only while a stream is still active.
150150- Once a stream completes or errors, its run state is cleaned up and reconnect returns ` null ` .
151+ - If reconnect finds stale inactive state and run-store cleanup fails, ` onError ` receives a
152+ ` "reconnect" ` phase event and reconnect still returns ` null ` .
151153- Provide a custom ` runStore ` if you need state shared across processes/instances.
152154
153155## ` ai.tool(...) ` example
You can’t perform that action at this time.
0 commit comments