Update app.py

app.py

@@ -106,9 +106,15 @@ def update_google_sheet():
         })
         timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
         print(f"Google sheet {name} successfully updated at {timestamp}! \n{global_df}")
-        
+        print(f"------------------------------------------------------------------------")
+    except Exception as e:
+        print(f"on_message Error: {e}")
 
 
+def update_google_sheet2():
+    """save data from HF Space -> google sheets (makes 2 API calls)"""
+    try:
+        """
         worksheet2.format(f"E1:E{len(worksheet2_df.index)+1}", {
         	"numberFormat": {
         		"type": 'TEXT',
@@ -119,6 +125,7 @@ def update_google_sheet():
         		"type": 'TEXT',
         	},
         })              
+        """
         name2 = "hf_discord_verified_users_test"
         # could just do this / format
         worksheet2['discord_user_id'] = worksheet2['discord_user_id'].astype(str)
@@ -126,18 +133,16 @@ def update_google_sheet():
         print(worksheet2_df.dtypes)
         set_with_dataframe(worksheet2, worksheet2_df)
         # very important, otherwise gspread will force format IDs in scientific notation by default (making them unusable)
-  
-        
         timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
         print(f"Google sheet {name2} successfully updated at {timestamp}!")
-        print(f"------------------------------------------------------------------------")
     except Exception as e:
         print(f"on_message Error: {e}")
-
+        
 
 executor = ThreadPoolExecutor(max_workers=1)
 scheduler = BackgroundScheduler(executors={'default': executor})
 scheduler.add_job(update_google_sheet, trigger='interval', minutes=1, max_instances=1)
+scheduler.add_job(update_google_sheet2, trigger='interval', minutes=1, max_instances=1)
 scheduler.start()
 
 
@@ -159,7 +164,7 @@ async def periodic_api_test(): # needs rewrite, can do same thing and interact w
         for index, user in enumerate(worksheet2_df['hf_user_name']):
             if user in processed_users:
                 continue
-            await asyncio.sleep(0.1)
+            await asyncio.sleep(0.5)
             url = f"https://huggingface.co/api/users/{user}/overview"
             response = requests.get(url)