Skip to content

Commit eb70542

Browse files
committed
remove unused function
1 parent 480f967 commit eb70542

File tree

1 file changed

+0
-24
lines changed

1 file changed

+0
-24
lines changed

apps/webapp/app/services/inputStreamWaitpointCache.server.ts

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -77,30 +77,6 @@ export async function getInputStreamWaitpoint(
7777
}
7878
}
7979

80-
/**
81-
* Atomically get and delete the waitpoint ID for an input stream.
82-
* Uses GETDEL for atomicity — only one concurrent `.send()` call will get the ID.
83-
* Called from the `.send()` route.
84-
*/
85-
export async function getAndDeleteInputStreamWaitpoint(
86-
runFriendlyId: string,
87-
streamId: string
88-
): Promise<string | null> {
89-
if (!redis) return null;
90-
91-
try {
92-
const key = buildKey(runFriendlyId, streamId);
93-
return await redis.getdel(key);
94-
} catch (error) {
95-
logger.error("Failed to get input stream waitpoint cache", {
96-
runFriendlyId,
97-
streamId,
98-
error,
99-
});
100-
return null;
101-
}
102-
}
103-
10480
/**
10581
* Delete the cache entry for an input stream waitpoint.
10682
* Called when a waitpoint is completed or timed out.

0 commit comments

Comments
 (0)