From e6e872dd40f09c13ac81f96bf2df58b0580e1fd2 Mon Sep 17 00:00:00 2001 From: Bakar Tavadze Date: Fri, 29 Mar 2024 20:39:52 +0400 Subject: [PATCH] Minor fix. --- tools/redis_to_postgres/migrate_data.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tools/redis_to_postgres/migrate_data.py b/tools/redis_to_postgres/migrate_data.py index ab16d5f9..84cfd9a0 100644 --- 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)