merge from improvements on the 1.0 branch:

[monitor.git] / pcubad.py

diff --git a/pcubad.py b/pcubad.py
index b31599f..181f001 100755 (executable)
--- a/pcubad.py
+++ b/pcubad.py
@@ -11,10 +11,11 @@ from pcucontrol  import reboot
 from monitor import parser as parsermodule
 from monitor import config
 from monitor.database.info.model import HistoryPCURecord, FindbadPCURecord
 from monitor import parser as parsermodule
 from monitor import config
 from monitor.database.info.model import HistoryPCURecord, FindbadPCURecord

+from monitor.database.dborm import mon_session as session

 from monitor.wrapper import plc,plccache
 from monitor.const import MINUP
 
 from monitor.wrapper import plc,plccache
 from monitor.const import MINUP
 

-from nodecommon import *
+from monitor.common import *

 from nodequery import verify,query_to_dict,node_select
 from monitor.model import *
 
 from nodequery import verify,query_to_dict,node_select
 from monitor.model import *
 


@@ -93,6 +94,7 @@ def checkAndRecordState(l_pcus, l_plcpcus):
        # replace with another operations that also commits all pending ops, such
        # as session.commit() or flush() or something
        print HistoryPCURecord.query.count()
        # replace with another operations that also commits all pending ops, such
        # as session.commit() or flush() or something
        print HistoryPCURecord.query.count()

+       session.flush()

 
        return True
 
 
        return True