From 05daa758f71d57c2a1f19859239fdecb359eae7a Mon Sep 17 00:00:00 2001 From: ZhongFuze Date: Fri, 8 Nov 2024 16:03:49 +0800 Subject: [PATCH] [!] re-run farcaster --- src/jobs/farcaster_graphdb_job.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/jobs/farcaster_graphdb_job.py b/src/jobs/farcaster_graphdb_job.py index 3763c58..a803c5e 100644 --- a/src/jobs/farcaster_graphdb_job.py +++ b/src/jobs/farcaster_graphdb_job.py @@ -4,7 +4,7 @@ Author: Zella Zhong Date: 2024-09-27 00:12:32 LastEditors: Zella Zhong -LastEditTime: 2024-10-30 02:27:41 +LastEditTime: 2024-11-08 16:03:24 FilePath: /data_process/src/jobs/farcaster_graphdb_job.py Description: ''' @@ -321,7 +321,12 @@ def process_farcaster_identity_graph(self): # Case multiple account hold by one address, the graph_id need to generate by it's address logging.debug("Start assign_address_graph_id...") - multaccount_final_df = multaccount_merged_df.groupby('address_unique_id').apply(assign_address_graph_id).reset_index(drop=True) + multaccount_final_df = multaccount_merged_df.groupby('farcaster_unique_id').apply(assign_graph_id).reset_index(drop=True) + # update the combine graph_id + multaccount_final_df['graph_id_farcaster'] = multaccount_final_df['final_graph_id'] + multaccount_final_df['updated_nanosecond_farcaster'] = multaccount_final_df['final_updated_nanosecond'] + # merge again + multaccount_final_df = multaccount_final_df.groupby('address_unique_id').apply(assign_address_graph_id).reset_index(drop=True) logging.debug("End assign_address_graph_id...") else: multaccount_final_df = pd.DataFrame(columns=['fname', 'network', 'address', 'farcaster_unique_id', 'address_unique_id',