Apply patch

2026-09-09 19:27:54 +02:00 · 2025-07-15 23:37:47 +00:00
parent 290313b7bd
commit 2126380cf1
1 changed files with 3 additions and 2 deletions
@@ -440,7 +440,7 @@ class ShallowPostgresSaver(BasePostgresSaver):
                (
                    thread_id,
                    checkpoint_ns,
-                    Jsonb(copy),
+                    Jsonb(self.serde.dumps_typed(copy)[1]),
                    Jsonb(get_checkpoint_metadata(config, metadata)),
                ),
            )
@@ -773,7 +773,7 @@ class AsyncShallowPostgresSaver(BasePostgresSaver):
                (
                    thread_id,
                    checkpoint_ns,
-                    Jsonb(copy),
+                    Jsonb(self.serde.dumps_typed(copy)[1]),
                    Jsonb(get_checkpoint_metadata(config, metadata)),
                ),
            )
@@ -957,3 +957,4 @@ class AsyncShallowPostgresSaver(BasePostgresSaver):
        return asyncio.run_coroutine_threadsafe(
            self.aput_writes(config, writes, task_id, task_path), self.loop
        ).result()
+