Skip to content

Commit e15f826

Browse files
committed
fix(webapp): forward the resolved S2 basin host to the task writer
1 parent b72a247 commit e15f826

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

apps/webapp/app/services/realtime/s2realtimeStreams.server.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ export class S2RealtimeStreams implements StreamResponder, StreamIngestor {
193193
"X-S2-Basin": this.basin,
194194
"X-S2-Flush-Interval-Ms": this.flushIntervalMs.toString(),
195195
"X-S2-Max-Retries": this.maxRetries.toString(),
196-
...(this.endpoint ? { "X-S2-Endpoint": this.endpoint } : {}),
196+
"X-S2-Endpoint": this.baseUrl,
197197
},
198198
};
199199
}

packages/trigger-sdk/src/v3/ai.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6068,7 +6068,9 @@ function chatAgent<
60686068
* in-flight `.in` message dispatches it as the first turn. The recovery
60696069
* block already advanced the `.in` cursor past the recovered message,
60706070
* so the preload wait below would otherwise strand it (the run would
6071-
* sit waiting for a "first message" that already arrived).
6071+
* sit waiting for a "first message" that already arrived). `onPreload`
6072+
* is a one-time start-of-run hook and is deliberately not re-run on a
6073+
* recovered/continuation turn.
60726074
*/
60736075
let dispatchedRecoveredFirstTurn = false;
60746076
if (preloaded && bootInjectedQueue.length > 0) {

0 commit comments

Comments
 (0)