chore: lint files

langchain-ai · Dec 10, 2024 · 949db54 · 949db54
1 parent cfda3d5
commit 949db54
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 16 deletions.
diff --git a/libs/checkpoint/src/memory.ts b/libs/checkpoint/src/memory.ts
@@ -78,13 +78,15 @@ export class MemorySaver extends BaseCheckpointSaver {
           pending_sends,
         };
         const pendingWrites: CheckpointPendingWrite[] = await Promise.all(
-          Object.values(this.writes[key] || {}).map(async ([taskId, channel, value]) => {
-            return [
-              taskId,
-              channel,
-              await this.serde.loadsTyped("json", value),
-            ];
-          })
+          Object.values(this.writes[key] || {}).map(
+            async ([taskId, channel, value]) => {
+              return [
+                taskId,
+                channel,
+                await this.serde.loadsTyped("json", value),
+              ];
+            }
+          )
         );
         const checkpointTuple: CheckpointTuple = {
           config,
@@ -126,13 +128,15 @@ export class MemorySaver extends BaseCheckpointSaver {
           pending_sends,
         };
         const pendingWrites: CheckpointPendingWrite[] = await Promise.all(
-          Object.values(this.writes[key] || {}).map(async ([taskId, channel, value]) => {
-            return [
-              taskId,
-              channel,
-              await this.serde.loadsTyped("json", value),
-            ];
-          })
+          Object.values(this.writes[key] || {}).map(
+            async ([taskId, channel, value]) => {
+              return [
+                taskId,
+                channel,
+                await this.serde.loadsTyped("json", value),
+              ];
+            }
+          )
         );
         const checkpointTuple: CheckpointTuple = {
           config: {

diff --git a/libs/langgraph/src/tests/pregel.test.ts b/libs/langgraph/src/tests/pregel.test.ts
@@ -9188,7 +9188,7 @@ export function runPregelTests(
     });
   });
 
-  it.only("can throw a node interrupt multiple times in a single node", async () => {
+  it("can throw a node interrupt multiple times in a single node", async () => {
     const GraphAnnotation = Annotation.Root({
       myKey: Annotation<string>({
         reducer: (a, b) => a + b,
@@ -9251,7 +9251,9 @@ export function runPregelTests(
         config
       )
     );
-    expect(thirdResult[thirdResult.length - 1].myKey).toEqual("DEanswer 1 answer 2");
+    expect(thirdResult[thirdResult.length - 1].myKey).toEqual(
+      "DEanswer 1 answer 2"
+    );
     const thirdState = await graph.getState(config);
     expect(thirdState.tasks).toHaveLength(0);
   });