|
a/scripts/refresh-all-repos.py |
|
b/scripts/refresh-all-repos.py |
|
... |
|
... |
36 |
projects = {}
|
36 |
projects = {}
|
37 |
q_project = {}
|
37 |
q_project = {}
|
38 |
log.info('Refreshing repositories')
|
38 |
log.info('Refreshing repositories')
|
39 |
if options.clean:
|
39 |
if options.clean:
|
40 |
log.info('Removing all repository objects')
|
40 |
log.info('Removing all repository objects')
|
41 |
M.repository.RepoObject.query.remove()
|
|
|
42 |
M.repo.CommitDoc.m.remove({})
|
41 |
M.repo.CommitDoc.m.remove({})
|
43 |
M.repo.TreeDoc.m.remove({})
|
42 |
M.repo.TreeDoc.m.remove({})
|
44 |
M.repo.TreesDoc.m.remove({})
|
43 |
M.repo.TreesDoc.m.remove({})
|
45 |
M.repo.DiffInfoDoc.m.remove({})
|
44 |
M.repo.DiffInfoDoc.m.remove({})
|
46 |
M.repo.LastCommitDoc.m.remove({})
|
|
|
47 |
M.repo.CommitRunDoc.m.remove({})
|
45 |
M.repo.CommitRunDoc.m.remove({})
|
48 |
for chunk in utils.chunked_find(M.Project, q_project):
|
46 |
for chunk in utils.chunked_find(M.Project, q_project):
|
49 |
for p in chunk:
|
47 |
for p in chunk:
|
50 |
c.project = p
|
48 |
c.project = p
|
51 |
if projects:
|
49 |
if projects:
|
|
... |
|
... |
54 |
mount_points = [ ac.options.mount_point
|
52 |
mount_points = [ ac.options.mount_point
|
55 |
for ac in M.AppConfig.query.find(dict(project_id=p._id)) ]
|
53 |
for ac in M.AppConfig.query.find(dict(project_id=p._id)) ]
|
56 |
for app in (p.app_instance(mp) for mp in mount_points):
|
54 |
for app in (p.app_instance(mp) for mp in mount_points):
|
57 |
c.app = app
|
55 |
c.app = app
|
58 |
if not hasattr(app, 'repo'): continue
|
56 |
if not hasattr(app, 'repo'): continue
|
59 |
if options.clean:
|
|
|
60 |
M.LastCommitFor.query.remove(dict(repo_id=c.app.repo._id))
|
|
|
61 |
try:
|
57 |
try:
|
62 |
c.app.repo._impl._setup_hooks()
|
58 |
c.app.repo._impl._setup_hooks()
|
63 |
except:
|
59 |
except:
|
64 |
log.exception('Error setting up hooks for %r', c.app.repo)
|
60 |
log.exception('Error setting up hooks for %r', c.app.repo)
|
65 |
try:
|
61 |
try:
|