Ling0925
/
suna
mirror of https://github.com/kortix-ai/suna.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rem 30min stream timeout fe

This commit is contained in:
marko-kraemer 2025-10-07 10:32:23 +02:00
parent 489f34b94d
commit 9166530351
1 changed files with 0 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
frontend/src/lib/api.ts
View File

@ -9,8 +9,6 @@ const API_URL = process.env.NEXT_PUBLIC_BACKEND_URL || '';
const nonRunningAgentRuns = new Set<string>();
// Map to keep track of active EventSource streams
const activeStreams = new Map<string, EventSource>();
// Map to keep track of safety timeouts
const safetyTimeouts = new Map<string, number>();
/**
* Helper function to safely cleanup EventSource connections
@ -31,13 +29,6 @@ const cleanupEventSource = (agentRunId: string, reason?: string): void => {
// Remove from active streams
activeStreams.delete(agentRunId);
}
// Clear any associated safety timeout
const timeout = safetyTimeouts.get(agentRunId);
if (timeout) {
clearTimeout(timeout);
safetyTimeouts.delete(agentRunId);
}
};
/**
@ -1066,17 +1057,6 @@ export const streamAgent = (
activeStreams.set(agentRunId, eventSource);
// Safety timeout to prevent indefinite connections (30 minutes)
const safetyTimeout = setTimeout(() => {
console.warn(`[STREAM] Safety timeout reached for ${agentRunId}, cleaning up`);
cleanupEventSource(agentRunId, 'safety timeout');
callbacks.onError('Connection timeout - stream has been running too long');
callbacks.onClose();
}, 30 * 60 * 1000); // 30 minutes
// Store the timeout ID for cleanup
safetyTimeouts.set(agentRunId, safetyTimeout as unknown as number);
eventSource.onopen = () => {
console.log(`[STREAM] EventSource opened for ${agentRunId}`);
};