From f38b3e8ddcbf3175565a75ed1ebfde1a67c2e5b8 Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Thu, 1 Feb 2024 16:11:50 +0330 Subject: [PATCH] update: thread metada key update! the update is to match everything on discord summaries metadata. --- .../src/db/discord/utils/transform_discord_raw_messges.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dags/hivemind_etl_helpers/src/db/discord/utils/transform_discord_raw_messges.py b/dags/hivemind_etl_helpers/src/db/discord/utils/transform_discord_raw_messges.py index 3d426ed6..b6ee79c8 100644 --- a/dags/hivemind_etl_helpers/src/db/discord/utils/transform_discord_raw_messges.py +++ b/dags/hivemind_etl_helpers/src/db/discord/utils/transform_discord_raw_messges.py @@ -164,7 +164,7 @@ def prepare_document( "date": message["createdDate"].strftime("%Y-%m-%d %H:%M:%S"), "author_username": author_name[0], # always including the thread_name, if `None`, then it was a channel message - "thread_name": message["threadName"], + "thread": message["threadName"], } if author_global_name[0] is not None: msg_meta_data["author_global_name"] = author_global_name[0] @@ -223,7 +223,7 @@ def prepare_document( "reactors_username", "reactors_global_name", "reactors_nicknames", - "thread_name", + "thread", "url_reference", "replier_username", "replier_global_name", @@ -239,7 +239,7 @@ def prepare_document( "reactors_username", "reactors_global_name", "reactors_nicknames", - "thread_name", + "thread", "url_reference", "replier_username", "replier_global_name",