Resolve TypeError when processing evaluation queue data
Browse files
app.py
CHANGED
@@ -321,16 +321,16 @@ with demo:
|
|
321 |
# Update evaluation tables periodically
|
322 |
def update_evaluation_tables():
|
323 |
finished_eval_queue_df, running_eval_queue_df, pending_eval_queue_df = get_evaluation_queue_df(EVAL_REQUESTS_PATH, EVAL_COLS)
|
324 |
-
|
325 |
-
running_eval_table.update(value=running_eval_queue_df)
|
326 |
-
pending_eval_table.update(value=pending_eval_queue_df)
|
327 |
|
328 |
# Setup schedulers
|
329 |
scheduler = BackgroundScheduler()
|
330 |
scheduler.add_job(restart_space, "interval", seconds=1800)
|
331 |
scheduler.add_job(process_evaluation_queue, "interval", seconds=300) # Process queue every 5 minutes
|
332 |
-
scheduler.add_job(update_evaluation_tables, 'interval', seconds=60) # Update evaluation tables every 60 seconds
|
333 |
scheduler.start()
|
334 |
|
335 |
logger.info("Application startup complete")
|
336 |
demo.queue(default_concurrency_limit=40).launch()
|
|
|
|
|
|
|
|
321 |
# Update evaluation tables periodically
|
322 |
def update_evaluation_tables():
|
323 |
finished_eval_queue_df, running_eval_queue_df, pending_eval_queue_df = get_evaluation_queue_df(EVAL_REQUESTS_PATH, EVAL_COLS)
|
324 |
+
return finished_eval_queue_df, running_eval_queue_df, pending_eval_queue_df
|
|
|
|
|
325 |
|
326 |
# Setup schedulers
|
327 |
scheduler = BackgroundScheduler()
|
328 |
scheduler.add_job(restart_space, "interval", seconds=1800)
|
329 |
scheduler.add_job(process_evaluation_queue, "interval", seconds=300) # Process queue every 5 minutes
|
|
|
330 |
scheduler.start()
|
331 |
|
332 |
logger.info("Application startup complete")
|
333 |
demo.queue(default_concurrency_limit=40).launch()
|
334 |
+
|
335 |
+
# Update evaluation tables every 60 seconds
|
336 |
+
demo.load(update_evaluation_tables, outputs=[finished_eval_table, running_eval_table, pending_eval_table], every=60)
|