--- a/server/sources/pyrorql.py Fri Mar 05 17:22:41 2010 +0100
+++ b/server/sources/pyrorql.py Fri Mar 05 17:24:01 2010 +0100
@@ -182,6 +182,7 @@
self._query_cache.clear()
repo = self.repo
session = repo.internal_session()
+ source = repo.system_source
try:
for etype, extid in modified:
try:
@@ -191,7 +192,7 @@
rset = session.eid_rset(eid, etype)
entity = rset.get_entity(0, 0)
entity.complete(entity.e_schema.indexable_attributes())
- repo.index_entity(session, entity)
+ source.index_entity(session, entity)
except:
self.exception('while updating %s with external id %s of source %s',
etype, extid, self.uri)