equal
deleted
inserted
replaced
57 or not repo.config.source_enabled(source) |
57 or not repo.config.source_enabled(source) |
58 or not source.config['synchronize']): |
58 or not source.config['synchronize']): |
59 continue |
59 continue |
60 try: |
60 try: |
61 stats = source.pull_data(session) |
61 stats = source.pull_data(session) |
62 if stats['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['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() |
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() |