replace some print statements to stderr

[monitor.git] / commands / checksync.py

diff --git a/commands/checksync.py b/commands/checksync.py
index 2a17687..d92d60f 100755 (executable)
--- a/commands/checksync.py
+++ b/commands/checksync.py
@@ -3,29 +3,48 @@
 from monitor.database.info.model import *
 import sys
 
-fbquery = HistoryNodeRecord.query.all()
-hostnames = [ n.hostname for n in fbquery ]
 
 if True:
-       for hn in hostnames:
-               fbrec = FindbadNodeRecord.query.filter_by(hostname=hn).order_by(FindbadNodeRecord.version.desc()).first()
-               if len(fbrec.versions) >= 2:
-                       if fbrec.version != fbrec.versions[-2].version + 1:
-                               print fbrec.hostname, fbrec.version, fbrec.versions[-2].version
-                               fbrec.version = fbrec.versions[-2].version + 1
-                               fbrec.flush()
-
-       session.flush()
-
-fbquery = HistoryPCURecord.query.all()
-pcus = [ n.plc_pcuid for n in fbquery ]
-
-for pcuid in pcus:
-       fbrec = FindbadPCURecord.query.filter_by(plc_pcuid=pcuid).order_by(FindbadPCURecord.version.desc()).first()
-       if len(fbrec.versions) >= 2:
-               if fbrec.version != fbrec.versions[-2].version + 1:
-                       print fbrec.plc_pcuid, fbrec.version, fbrec.versions[-2].version
-                       fbrec.version = fbrec.versions[-2].version + 1
-                       fbrec.flush()
+    fbquery = HistorySiteRecord.query.all()
+    loginbases = [ h.loginbase for h in fbquery ]
+
+    for lb in loginbases:
+        h = HistorySiteRecord.query.filter_by(loginbase=lb).first()
+        if len(h.versions) >= 2:
+            if h.version != h.versions[-2].version + 1:
+                print h.loginbase, h.version, h.versions[-2].version
+                h.version = h.versions[-2].version + 1
+                h.flush()
+
+    session.flush()
+
+
+
+if True:
+    fbquery = HistoryNodeRecord.query.all()
+    hostnames = [ n.hostname for n in fbquery ]
+
+    for hn in hostnames:
+        fbrec = FindbadNodeRecord.query.filter_by(hostname=hn).order_by(FindbadNodeRecord.version.desc()).first()
+        if len(fbrec.versions) >= 2:
+            if fbrec.version != fbrec.versions[-2].version + 1:
+                print fbrec.hostname, fbrec.version, fbrec.versions[-2].version
+                fbrec.version = fbrec.versions[-2].version + 1
+                fbrec.flush()
+
+    session.flush()
+
+
+if True:
+    fbquery = HistoryPCURecord.query.all()
+    pcus = [ n.plc_pcuid for n in fbquery ]
+
+    for pcuid in pcus:
+        fbrec = FindbadPCURecord.query.filter_by(plc_pcuid=pcuid).order_by(FindbadPCURecord.version.desc()).first()
+        if len(fbrec.versions) >= 2:
+            if fbrec.version != fbrec.versions[-2].version + 1:
+                print fbrec.plc_pcuid, fbrec.version, fbrec.versions[-2].version
+                fbrec.version = fbrec.versions[-2].version + 1
+                fbrec.flush()
 
 session.flush()