@@ -27,12 +27,10 @@ export class ManagedRuntimeManager implements RuntimeManager {
27
27
private ipc : ExecutorToWorkerProcessConnection ,
28
28
private showLogs : boolean
29
29
) {
30
- setTimeout ( ( ) => {
31
- this . log ( "Runtime status" , {
32
- resolversbyWaitId : this . resolversByWaitId . keys ( ) ,
33
- resolversByWaitpoint : this . resolversByWaitpoint . keys ( ) ,
34
- } ) ;
35
- } , 1000 ) ;
30
+ // Log out the runtime status on a long interval to help debug stuck executions
31
+ setInterval ( ( ) => {
32
+ this . log ( "[DEBUG] ManagedRuntimeManager status" , this . status ) ;
33
+ } , 300_000 ) ;
36
34
}
37
35
38
36
disable ( ) : void {
@@ -178,14 +176,14 @@ export class ManagedRuntimeManager implements RuntimeManager {
178
176
}
179
177
180
178
if ( ! waitId ) {
181
- this . log ( "No waitId found for waitpoint" , waitpoint ) ;
179
+ this . log ( "No waitId found for waitpoint" , { ... this . status , ... waitpoint } ) ;
182
180
return ;
183
181
}
184
182
185
183
const resolve = this . resolversByWaitId . get ( waitId ) ;
186
184
187
185
if ( ! resolve ) {
188
- this . log ( "No resolver found for waitId" , waitId ) ;
186
+ this . log ( "No resolver found for waitId" , { ... this . status , waitId } ) ;
189
187
return ;
190
188
}
191
189
@@ -227,4 +225,11 @@ export class ManagedRuntimeManager implements RuntimeManager {
227
225
if ( ! this . showLogs ) return ;
228
226
console . log ( `[${ new Date ( ) . toISOString ( ) } ] ${ message } ` , args ) ;
229
227
}
228
+
229
+ private get status ( ) {
230
+ return {
231
+ resolversbyWaitId : Array . from ( this . resolversByWaitId . keys ( ) ) ,
232
+ resolversByWaitpoint : Array . from ( this . resolversByWaitpoint . keys ( ) ) ,
233
+ } ;
234
+ }
230
235
}
0 commit comments