from math import ceil
import transaction
from ZODB.POSException import ConflictError
+from ZODB.POSException import ConnectionStateError
from zope.site.hooks import setSite
from cStringIO import StringIO
self._process(app)
con = app._p_jar
- con.close()
- #con.close()
+ try :
+ con.close()
+ except ConnectionStateError, e :
+ console.warn('ConnectionStateError raised before finished.')
console.info('process finished.')
- #print con
- #print con.transaction_manager
def stop(self):
pass
p.tiles_available = 1
-
- portal = app.unrestrictedTraverse(self.portal_path)
- ctool = portal.portal_catalog
- uid = '/'.join(p.getPhysicalPath())
- ctool.reindexObject(p, idxs=['tiles_available'], uid=uid)
+ assert p._getCatalogTool()
+ p.reindexObject(idxs=['tiles_available'])
transaction.commit()
except ConflictError :