Update listend.py

fixed quick bug due to double header writes during rotations
TACC · Apr 7, 2016 · 6e1b7b6 · 6e1b7b6
1 parent 8c2e4e9
commit 6e1b7b6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/tacc_stats/listend.py b/tacc_stats/listend.py
@@ -19,8 +19,9 @@ def on_message(channel, method_frame, header_frame, body):
 
         with open(current_path, 'w') as fd:
             link_path = os.path.join(host_dir, str(int(time.time())))
-            if not os.path.exists(link_path):
-                os.link(current_path, link_path)
+            if os.path.exists(link_path):
+                os.remove(link_path)
+            os.link(current_path, link_path)
 
     with open(current_path, 'a') as fd:
         fd.write(body)