equal
deleted
inserted
replaced
55 for source in repo.sources_by_eid.itervalues(): |
55 for source in repo.sources_by_eid.itervalues(): |
56 if (not source.copy_based_source |
56 if (not source.copy_based_source |
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 session = repo.internal_session() |
60 session = repo.internal_session(safe=True) |
61 try: |
61 try: |
62 stats = source.pull_data(session) |
62 stats = source.pull_data(session) |
63 if stats.get('created'): |
63 if stats.get('created'): |
64 source.info('added %s entities', len(stats['created'])) |
64 source.info('added %s entities', len(stats['created'])) |
65 if stats.get('updated'): |
65 if stats.get('updated'): |