update

app.py

@@ -13,62 +13,67 @@ MAX_RETRIES = 3
 
 def commit_signup(username: str) -> Optional[str]:
     """Attempt to commit new signup atomically, always reading latest data before commit"""
-   # 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:
-            operation = CommitOperationAdd(
-                path_in_repo="waitlist.csv",
-                path_or_fileobj=tmp.name
-            )
-        except Exception as e:
-            print(f"CommitOperationAdd {str(e)}")     
-
+        # Always get the latest data right before committing
         try:
-            create_commit(                    repo_id=DATASET_REPO,
+            file_content = hf_api.hf_hub_download(
+                repo_id=DATASET_REPO,
                 repo_type="dataset",
-                operations=[operation],
-                commit_message=f"Add user {username} to waitlist",
-                token=os.getenv("HF_TOKEN"),
+                filename="waitlist.csv",
+                token=os.getenv("HF_TOKEN")
             )
-            os.unlink(tmp.name)
-            return None
+            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"Second error {str(e)}")
-            os.unlink(tmp.name)
-            return str(e)
-   # except Exception as e:
-   #     return str(e)
+            print(f"First error {str(e)}")
+            current_data = pd.DataFrame(columns=['userid', 'joined_at'])
+        print("we make it here")
+        # 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()
+        }])
+        print("new row")
+        
+        # Combine with latest data
+        updated_data = pd.concat([current_data, new_row], ignore_index=True)
+        print("updated data")
+
+        # 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)}")     
+        print("commit operation")
+
+            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"),
+                )
+                print("commit created")
+                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)
 
 def join_waitlist(
     profile: gr.OAuthProfile | None,