[!] re-run farcaster

web3bio · Nov 8, 2024 · 05daa75 · 05daa75
1 parent f4e89e8
commit 05daa75
Showing 1 changed file with 7 additions and 2 deletions.
diff --git 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',