record_wf: force flush every 60 lines

record_wf.py

@@ -9,17 +9,19 @@ import os
 
 last_date = None
 logfile = None
+nwrite = 0
 
 os.makedirs("logs", exist_ok=True)
 
 def write_log(dt, line):
-    global last_date, logfile
+    global last_date, logfile, nwrite
 
     date = dt.date()
 
     # reopen log file if day has changed
     if last_date != date:
         if logfile:
+            logfile.flush()
             logfile.close()
 
         logname = os.path.join("logs", date.strftime("%Y-%m-%d.csv"))
@@ -33,6 +35,11 @@ def write_log(dt, line):
 
     logfile.write(line)
 
+    nwrite += 1
+    if nwrite >= 60:
+        nwrite = 0
+        logfile.flush()
+
 
 last_keepalive = datetime.datetime.now()