update app.py
Browse files
__pycache__/DB_utls.cpython-311.pyc
CHANGED
|
Binary files a/__pycache__/DB_utls.cpython-311.pyc and b/__pycache__/DB_utls.cpython-311.pyc differ
|
|
|
__pycache__/prefect_utils.cpython-311.pyc
CHANGED
|
Binary files a/__pycache__/prefect_utils.cpython-311.pyc and b/__pycache__/prefect_utils.cpython-311.pyc differ
|
|
|
__pycache__/yt_utils.cpython-311.pyc
CHANGED
|
Binary files a/__pycache__/yt_utils.cpython-311.pyc and b/__pycache__/yt_utils.cpython-311.pyc differ
|
|
|
app.py
CHANGED
|
@@ -209,7 +209,7 @@ def task_processor():
|
|
| 209 |
processor_thread = threading.Thread(target=task_processor, daemon=True)
|
| 210 |
processor_thread.start()
|
| 211 |
|
| 212 |
-
|
| 213 |
def verify_student_id(student_id):
|
| 214 |
"""Verify student ID and check quota"""
|
| 215 |
global queue_counter
|
|
@@ -309,8 +309,9 @@ def add_to_queue(student_id, R, Y, B):
|
|
| 309 |
try:
|
| 310 |
empty_wells = find_unused_wells()
|
| 311 |
if not empty_wells:
|
|
|
|
| 312 |
pause_flow_run(timeout=2)
|
| 313 |
-
print("[
|
| 314 |
raise ValueError("No available wells")
|
| 315 |
|
| 316 |
selected_well = empty_wells[0]
|
|
|
|
| 209 |
processor_thread = threading.Thread(target=task_processor, daemon=True)
|
| 210 |
processor_thread.start()
|
| 211 |
|
| 212 |
+
@flow
|
| 213 |
def verify_student_id(student_id):
|
| 214 |
"""Verify student ID and check quota"""
|
| 215 |
global queue_counter
|
|
|
|
| 309 |
try:
|
| 310 |
empty_wells = find_unused_wells()
|
| 311 |
if not empty_wells:
|
| 312 |
+
print("[DEBUG] About to pause flow")
|
| 313 |
pause_flow_run(timeout=2)
|
| 314 |
+
print("[DEBUG] Pause flow for 2 seconds")
|
| 315 |
raise ValueError("No available wells")
|
| 316 |
|
| 317 |
selected_well = empty_wells[0]
|