@@ -931,7 +931,9 @@ export class Pregel<
931931 const checkpointer =
932932 config . configurable ?. [ CONFIG_KEY_CHECKPOINTER ] ?? this . checkpointer ;
933933 if ( ! checkpointer ) {
934- throw new GraphValueError ( "No checkpointer set" ) ;
934+ throw new GraphValueError ( "No checkpointer set" , {
935+ lc_error_code : "MISSING_CHECKPOINTER" ,
936+ } ) ;
935937 }
936938
937939 const checkpointNamespace : string =
@@ -991,7 +993,9 @@ export class Pregel<
991993 const checkpointer : BaseCheckpointSaver =
992994 config . configurable ?. [ CONFIG_KEY_CHECKPOINTER ] ?? this . checkpointer ;
993995 if ( ! checkpointer ) {
994- throw new GraphValueError ( "No checkpointer set" ) ;
996+ throw new GraphValueError ( "No checkpointer set" , {
997+ lc_error_code : "MISSING_CHECKPOINTER" ,
998+ } ) ;
995999 }
9961000
9971001 const checkpointNamespace : string =
@@ -1065,7 +1069,9 @@ export class Pregel<
10651069 const checkpointer : BaseCheckpointSaver | undefined =
10661070 startConfig . configurable ?. [ CONFIG_KEY_CHECKPOINTER ] ?? this . checkpointer ;
10671071 if ( ! checkpointer ) {
1068- throw new GraphValueError ( "No checkpointer set" ) ;
1072+ throw new GraphValueError ( "No checkpointer set" , {
1073+ lc_error_code : "MISSING_CHECKPOINTER" ,
1074+ } ) ;
10691075 }
10701076 if ( supersteps . length === 0 ) {
10711077 throw new Error ( "No supersteps provided" ) ;
@@ -2038,12 +2044,7 @@ export class Pregel<
20382044 stream . push ( [ ns ?? [ ] , "custom" , chunk ] ) ;
20392045 } ;
20402046
2041- config . interrupt ??=
2042- this . checkpointer != null
2043- ? interrupt
2044- : ( ) => {
2045- throw new GraphValueError ( "No checkpointer set" ) ;
2046- } ;
2047+ config . interrupt ??= interrupt ;
20472048
20482049 const callbackManager = await getCallbackManagerForConfig ( config ) ;
20492050 const runManager = await callbackManager ?. handleChainStart (
0 commit comments