X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=monitor%2Fdatabase%2Finfo%2Ffindbad.py;h=dbe0eca4d1d3918a5ffbce9024ef3ea7bf42d428;hb=035a846d8617889c01cae12bc6d64eb7c48b64bd;hp=a5139eb33b9681e4dfc7bbf6c02e02369419c566;hpb=c9d06f3b274ecbc092a0b3eb1f5ceb6c0f734aad;p=monitor.git diff --git a/monitor/database/info/findbad.py b/monitor/database/info/findbad.py index a5139eb..dbe0eca 100644 --- a/monitor/database/info/findbad.py +++ b/monitor/database/info/findbad.py @@ -11,46 +11,22 @@ __metadata__ = mon_metadata __session__ = mon_session -#class FindbadNodeRecordSync(Entity): -# hostname = Field(String(250),primary_key=True) #,alternateMethodName='by_hostname') -# round = Field(Int,default=0) - -#class FindbadPCURecordSync(Entity): -# plc_pcuid = Field(Int,primary_key=True) #,alternateMethodName='by_pcuid') -# round = Field(Int,default=0) - class FindbadNodeRecord(Entity): @classmethod def get_all_latest(cls): return cls.query.all() - #fbsync = FindbadNodeRecordSync.get_by(hostname="global") - #if fbsync: - # return cls.query.filter_by(round=fbsync.round) - #else: - # return [] @classmethod def get_latest_by(cls, **kwargs): return cls.query.filter_by(**kwargs).first() - #fbsync = FindbadNodeRecordSync.get_by(hostname="global") - #if fbsync: - # kwargs['round'] = fbsync.round - # return cls.query.filter_by(**kwargs).order_by(FindbadNodeRecord.date_checked.desc()) - #else: - # return [] + + @classmethod + def get_latest_by(cls, **kwargs): + return cls.query.filter_by(**kwargs).first() @classmethod def get_latest_n_by(cls, n=3, **kwargs): return cls.query.filter_by(**kwargs) - #fbsync = FindbadNodeRecordSync.get_by(hostname="global") - #kwargs['round'] = fbsync.round - #ret = [] - #for i in range(0,n): - # kwargs['round'] = kwargs['round'] - i - # f = cls.query.filter_by(**kwargs).first() - # if f: - # ret.append(f) - #return ret # ACCOUNTING date_checked = Field(DateTime,default=datetime.now) @@ -99,7 +75,7 @@ class FindbadPCURecord(Entity): # ACCOUNTING date_checked = Field(DateTime) round = Field(Int,default=0) - plc_pcuid = Field(Int) #alternateID=True,alternateMethodName='by_pcuid') + plc_pcuid = Field(Int) # EXTERNAL plc_pcu_stats = Field(PickleType,default=None)