@@ -65,51 +65,4 @@ describe('legacy execution callback enqueue', () => {
6565 status : 'completed' ,
6666 } ) ;
6767 } ) ;
68-
69- it ( 'handles callback queue send failures without failing execution completion' , async ( ) => {
70- const userId = 'user_legacy_callback_failure' ;
71- const sessionId = 'agent_legacy_callback_failure' ;
72- const stub = env . CLOUD_AGENT_SESSION . get (
73- env . CLOUD_AGENT_SESSION . idFromName ( `${ userId } :${ sessionId } ` )
74- ) ;
75-
76- const result = await runInDurableObject ( stub , async instance => {
77- let attempted = false ;
78- installCallbackQueue ( instance , async ( ) => {
79- attempted = true ;
80- throw new Error ( 'queue unavailable' ) ;
81- } ) ;
82-
83- await registerReadySession ( instance , {
84- sessionId,
85- userId,
86- prompt : 'prepared prompt' ,
87- mode : 'code' ,
88- model : 'test-model' ,
89- kiloSessionId : '55555555-5555-4555-8555-555555555555' ,
90- kilocodeToken : 'token-callback-failure' ,
91- callbackTarget : { url : 'https://example.com/callback' } ,
92- } ) ;
93- await instance . addExecution ( {
94- executionId : 'exc_legacy_callback_failure' ,
95- mode : 'code' ,
96- streamingMode : 'websocket' ,
97- ingestToken : 'exc_legacy_callback_failure' ,
98- messageId : 'msg_018f1e2d3c4bCallFailAbCd' ,
99- } ) ;
100-
101- await instance . updateExecutionStatus ( {
102- executionId : 'exc_legacy_callback_failure' ,
103- status : 'running' ,
104- } ) ;
105- const update = await instance . updateExecutionStatus ( {
106- executionId : 'exc_legacy_callback_failure' ,
107- status : 'completed' ,
108- } ) ;
109-
110- return { attempted, updateOk : update . ok } ;
111- } ) ;
112-
113- expect ( result ) . toEqual ( { attempted : true , updateOk : true } ) ;
114- } ) ;
11568} ) ;
0 commit comments