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