equal
deleted
inserted
replaced
65 source.info('updated %s entities', len(stats['updated'])) |
65 source.info('updated %s entities', len(stats['updated'])) |
66 session.commit() |
66 session.commit() |
67 except Exception, exc: |
67 except Exception, exc: |
68 session.exception('while trying to update feed %s', source) |
68 session.exception('while trying to update feed %s', source) |
69 session.rollback() |
69 session.rollback() |
70 session.set_pool() |
70 session.set_cnxset() |
71 finally: |
71 finally: |
72 session.close() |
72 session.close() |
73 self.repo.looping_task(60, update_feeds, self.repo) |
73 self.repo.looping_task(60, update_feeds, self.repo) |