update

app.py

@@ -13,63 +13,62 @@ MAX_RETRIES = 3
 
 def commit_signup(username: str) -> Optional[str]:
     """Attempt to commit new signup atomically, always reading latest data before commit"""
-    try:
+   # try:
         # Always get the latest data right before committing
+    try:
+        file_content = hf_api.hf_hub_download(
+            repo_id=DATASET_REPO,
+            repo_type="dataset",
+            filename="waitlist.csv",
+            token=os.getenv("HF_TOKEN")
+        )
+        current_data = pd.read_csv(file_content)
+        if 'userid' not in current_data.columns or 'joined_at' not in current_data.columns:
+            current_data = pd.DataFrame(columns=['userid', 'joined_at'])
+    except Exception as e:
+        print(f"First error {str(e)}")
+        current_data = pd.DataFrame(columns=['userid', 'joined_at'])
+
+    # If user already exists in the latest data, don't add them again
+    if username in current_data['userid'].values:
+        return None
+
+    # Add new user with timestamp
+    new_row = pd.DataFrame([{
+        'userid': username,
+        'joined_at': datetime.utcnow().isoformat()
+    }])
+    
+    # Combine with latest data
+    updated_data = pd.concat([current_data, new_row], ignore_index=True)
+    
+    # Save to temp file
+    with tempfile.NamedTemporaryFile(mode='w', suffix='.csv', delete=False) as tmp:
+        updated_data.to_csv(tmp.name, index=False)
+        
         try:
-            file_content = hf_api.hf_hub_download(
-                repo_id=DATASET_REPO,
-                repo_type="dataset",
-                filename="waitlist.csv",
-                token=os.getenv("HF_TOKEN")
+            operation = CommitOperationAdd(
+                path_in_repo="waitlist.csv",
+                path_or_fileobj=tmp.name
             )
-            current_data = pd.read_csv(file_content)
-            if 'userid' not in current_data.columns or 'joined_at' not in current_data.columns:
-                current_data = pd.DataFrame(columns=['userid', 'joined_at'])
         except Exception as e:
-            print(f"First error {str(e)}")
-            current_data = pd.DataFrame(columns=['userid', 'joined_at'])
+            print(f"CommitOperationAdd {str(e)}")     
 
-        # If user already exists in the latest data, don't add them again
-        if username in current_data['userid'].values:
+        try:
+            create_commit(                    repo_id=DATASET_REPO,
+                repo_type="dataset",
+                operations=[operation],
+                commit_message=f"Add user {username} to waitlist",
+                token=os.getenv("HF_TOKEN"),
+            )
+            os.unlink(tmp.name)
             return None
-
-        # Add new user with timestamp
-        new_row = pd.DataFrame([{
-            'userid': username,
-            'joined_at': datetime.utcnow().isoformat()
-        }])
-        
-        # Combine with latest data
-        updated_data = pd.concat([current_data, new_row], ignore_index=True)
-        
-        # Save to temp file
-        with tempfile.NamedTemporaryFile(mode='w', suffix='.csv', delete=False) as tmp:
-            updated_data.to_csv(tmp.name, index=False)
-            
-            try:
-                operation = CommitOperationAdd(
-                    path_in_repo="waitlist.csv",
-                    path_or_fileobj=tmp.name
-                )
-            except Exception as e:
-                print(f"CommitOperationAdd {str(e)}")     
-                       
-            try:
-                create_commit(
-                    repo_id=DATASET_REPO,
-                    repo_type="dataset",
-                    operations=[operation],
-                    commit_message=f"Add user {username} to waitlist",
-                    token=os.getenv("HF_TOKEN"),
-                )
-                os.unlink(tmp.name)
-                return None
-            except Exception as e:
-                print(f"Second error {str(e)}")
-                os.unlink(tmp.name)
-                return str(e)
-    except Exception as e:
-        return str(e)
+        except Exception as e:
+            print(f"Second error {str(e)}")
+            os.unlink(tmp.name)
+            return str(e)
+   # except Exception as e:
+   #     return str(e)
 
 def join_waitlist(
     profile: gr.OAuthProfile | None,