Minor fix.

brighthive · Mar 29, 2024 · e6e872d · e6e872d
1 parent b00ddbd
commit e6e872d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tools/redis_to_postgres/migrate_data.py b/tools/redis_to_postgres/migrate_data.py
@@ -189,7 +189,7 @@ async def migrate_checkpoints() -> None:
         if checkpoint:
             if checkpoint.get("channel_values", {}).get("__root__"):
                 checkpoint["channel_values"]["__root__"] = [
-                    msg.__class__(**msg.__dict__.items())
+                    msg.__class__(**msg.__dict__)
                     for msg in checkpoint["channel_values"]["__root__"]
                 ]
             await postgres_checkpoint.aput(config, checkpoint)