fix pipe io bug

io_utils.py

@@ -95,13 +95,17 @@ def save_job_to_pipe(id, job, lock):
 def pop_job_from_pipe():
     if not os.path.exists(PIPE_PATH):
         return
-    with open(PIPE_PATH, "r+") as f:
-        jobs = f.readlines()
-        f.write("\n".join(jobs[1:]))
+    with open(PIPE_PATH, "r") as f:
+        job = f.readline().strip()
+        remaining = f.readlines()
         f.close()
-    if len(jobs) == 0:
+    print(job, remaining, ">>>>")
+    with open(PIPE_PATH, "w") as f:
+        f.write("\n".join(remaining))
+        f.close()
+    if len(job) == 0:
         return
-    job_info = jobs[0].split('\n')[0].split("@")
+    job_info = job.split('\n')[0].split("@")
     if len(job_info) != 2:
         raise ValueError("Invalid job info: ", job_info)
     print(f"Running job {job_info}")