equal
deleted
inserted
replaced
132 register_persistent_options(myoptions) |
132 register_persistent_options(myoptions) |
133 self._query_cache = TimedCache(30) |
133 self._query_cache = TimedCache(30) |
134 |
134 |
135 def last_update_time(self): |
135 def last_update_time(self): |
136 pkey = u'sources.%s.latest-update-time' % self.uri |
136 pkey = u'sources.%s.latest-update-time' % self.uri |
137 rql = 'Any V WHERE X is EProperty, X value V, X pkey %(k)s' |
137 rql = 'Any V WHERE X is CWProperty, X value V, X pkey %(k)s' |
138 session = self.repo.internal_session() |
138 session = self.repo.internal_session() |
139 try: |
139 try: |
140 rset = session.execute(rql, {'k': pkey}) |
140 rset = session.execute(rql, {'k': pkey}) |
141 if not rset: |
141 if not rset: |
142 # insert it |
142 # insert it |
143 session.execute('INSERT EProperty X: X pkey %(k)s, X value %(v)s', |
143 session.execute('INSERT CWProperty X: X pkey %(k)s, X value %(v)s', |
144 {'k': pkey, 'v': u'0'}) |
144 {'k': pkey, 'v': u'0'}) |
145 session.commit() |
145 session.commit() |
146 timestamp = 0 |
146 timestamp = 0 |
147 else: |
147 else: |
148 assert len(rset) == 1 |
148 assert len(rset) == 1 |