Display current job

app_debug.py

@@ -39,8 +39,10 @@ def get_accordions_of_config_files():
 def get_demo(demo):
     with gr.Row():
         # check if jobs is an attribute of pipe
-        if hasattr(pipe, "jobs"):
-            gr.Markdown(f"current jobs in queue: {len(pipe.jobs)}")
+        if hasattr(pipe, "jobs") and len(pipe.jobs) > 0:
+            gr.Markdown(f"Current job: {pipe.current} Jobs in queue: {len(pipe.jobs)}")
+        else:
+            gr.Markdown("No jobs in queue, please submit an evaluation task.")
     with gr.Accordion(label="Config Files", open=False):
         config_accordion = get_accordions_of_config_files()
         demo.load(get_accordions_of_config_files, outputs=config_accordion, every=1)

io_utils.py

@@ -125,15 +125,16 @@ def write_log_to_user_file(id, log):
     f.close()
 
 
-def save_job_to_pipe(id, job, lock):
+def save_job_to_pipe(id, job, description="", lock):
     with lock:
-        pipe.jobs.append((id, job))
+        pipe.jobs.append((id, job, description))
 
 
 def pop_job_from_pipe():
     if len(pipe.jobs) == 0:
         return
     job_info = pipe.jobs.pop()
+    pipe.current = job_info[2]
     write_log_to_user_file(job_info[0], f"Running job id {job_info[0]}\n")
     command = job_info[1]
 

pipe.py

@@ -1,3 +1,3 @@
-def init():
-    global jobs
-    jobs = list()
+
+jobs = list()
+current = None

text_classification_ui_helpers.py

@@ -247,7 +247,7 @@ def try_submit(m_id, d_id, config, split, local, uid):
 
         eval_str = f"[{m_id}]<{d_id}({config}, {split} set)>"
         logging.info(f"Start local evaluation on {eval_str}")
-        save_job_to_pipe(uid, command, threading.Lock())
+        save_job_to_pipe(uid, command, eval_str, threading.Lock())
         write_log_to_user_file(
             uid,
             f"Start local evaluation on {eval_str}. Please wait for your job to start...\n",