revoke verifiy id function

app.py

@@ -8,18 +8,8 @@ import secrets
 from DB_utils import find_unused_wells, update_used_wells, save_result, get_student_quota, decrement_student_quota
 import os
 from yt_utils import get_latest_video_id
-from prefect import task, flow, pause_flow_run, resume_flow_run
+from prefect import flow 
 from prefect_utils import start_prefect_worker
-from prefect import get_run_logger, settings
-from prefect.blocks.notifications import SlackWebhook
-from prefect.context import get_run_context
-from prefect.input import RunInput
-
-class VerificationInput(RunInput):
-    approved: bool
-    comments: str = ""
-
-
 
 # NOTE: New global dict to store tasks keyed by (student_id, experiment_id)
 tasks_dict = {}
@@ -30,8 +20,6 @@ current_task = None
 sensor_results = None
 queue_counter = task_queue.qsize()
 
-
-
 MQTT_BROKER = os.getenv("MQTT_BROKER")
 MQTT_PORT = int(os.getenv("MQTT_PORT"))
 MQTT_USERNAME = os.getenv("MQTT_USERNAME")
@@ -232,32 +220,16 @@ def verify_student_id(student_id):
     
     quota_remaining = check_student_quota(student_id)
     
-    logger = get_run_logger()
-    flow_run = get_run_context().flow_run
-    logger.info(f"Student ID: {student_id} requested verification. Quota remaining: {quota_remaining}")
-
-    if flow_run and settings.PREFECT_UI_URL:
-        flow_run_url = f"{settings.PREFECT_UI_URL.value()}/flow-runs/flow-run/{flow_run.id}"
-        logger.info(f"Please review and resume the flow here: {flow_run_url}")
-
-    user_input = pause_flow_run(
-        wait_for_input=VerificationInput.with_initial_data(
-            description="Approve this Student ID to continue the experiment?",
-            approved=False,
-            comments="",
-        ),
-        timeout=300,  # 10 minutes
-    )
-
-    if not user_input.approved:
+    
+    if quota_remaining <= 0:
         return [
             gr.update(interactive=False, value=0),
             gr.update(interactive=False, value=0),
             gr.update(interactive=False, value=0),
-            "Student verification rejected",
+            "No experiments remaining. Please contact administrator.",
             gr.update(interactive=False)
         ]
-
+    
     return [
         gr.update(interactive=True, value=0),
         gr.update(interactive=True, value=0),
@@ -265,7 +237,6 @@ def verify_student_id(student_id):
         f"Student ID verified. Available experiments: {quota_remaining}\nCurrent queue length: {queue_counter} experiment(s)",
         gr.update(interactive=True)
     ]
-
 def update_status_with_queue(R, Y, B):
     """Check if RYB inputs are valid and return updated queue info"""
     global queue_counter