Merge "Track bug_modified_since per project"
This commit is contained in:
commit
13dc944373
@ -96,7 +96,7 @@ def _process_reviews(record_iterator, ci_map, module, branch):
|
|||||||
|
|
||||||
|
|
||||||
def _process_repo(repo, runtime_storage_inst, record_processor_inst,
|
def _process_repo(repo, runtime_storage_inst, record_processor_inst,
|
||||||
rcs_inst, bug_modified_since):
|
rcs_inst):
|
||||||
uri = repo['uri']
|
uri = repo['uri']
|
||||||
LOG.info('Processing repo uri: %s', uri)
|
LOG.info('Processing repo uri: %s', uri)
|
||||||
|
|
||||||
@ -109,6 +109,10 @@ def _process_repo(repo, runtime_storage_inst, record_processor_inst,
|
|||||||
utils.merge_records)
|
utils.merge_records)
|
||||||
|
|
||||||
LOG.debug('Processing bugs for repo uri: %s', uri)
|
LOG.debug('Processing bugs for repo uri: %s', uri)
|
||||||
|
current_date = utils.date_to_timestamp('now')
|
||||||
|
bug_modified_since = runtime_storage_inst.get_by_key(
|
||||||
|
'bug_modified_since-%s' % repo['module'])
|
||||||
|
|
||||||
bug_iterator = bps.log(repo, bug_modified_since)
|
bug_iterator = bps.log(repo, bug_modified_since)
|
||||||
bug_iterator_typed = _record_typer(bug_iterator, 'bug')
|
bug_iterator_typed = _record_typer(bug_iterator, 'bug')
|
||||||
processed_bug_iterator = record_processor_inst.process(
|
processed_bug_iterator = record_processor_inst.process(
|
||||||
@ -116,6 +120,9 @@ def _process_repo(repo, runtime_storage_inst, record_processor_inst,
|
|||||||
runtime_storage_inst.set_records(processed_bug_iterator,
|
runtime_storage_inst.set_records(processed_bug_iterator,
|
||||||
utils.merge_records)
|
utils.merge_records)
|
||||||
|
|
||||||
|
runtime_storage_inst.set_by_key(
|
||||||
|
'bug_modified_since-%s' % repo['module'], current_date)
|
||||||
|
|
||||||
vcs_inst = vcs.get_vcs(repo, cfg.CONF.sources_root)
|
vcs_inst = vcs.get_vcs(repo, cfg.CONF.sources_root)
|
||||||
vcs_inst.fetch()
|
vcs_inst.fetch()
|
||||||
|
|
||||||
@ -201,21 +208,16 @@ def _post_process_records(record_processor_inst, repos):
|
|||||||
def process(runtime_storage_inst, record_processor_inst):
|
def process(runtime_storage_inst, record_processor_inst):
|
||||||
repos = utils.load_repos(runtime_storage_inst)
|
repos = utils.load_repos(runtime_storage_inst)
|
||||||
|
|
||||||
current_date = utils.date_to_timestamp('now')
|
|
||||||
bug_modified_since = runtime_storage_inst.get_by_key('bug_modified_since')
|
|
||||||
|
|
||||||
rcs_inst = rcs.get_rcs(cfg.CONF.review_uri)
|
rcs_inst = rcs.get_rcs(cfg.CONF.review_uri)
|
||||||
rcs_inst.setup(key_filename=cfg.CONF.ssh_key_filename,
|
rcs_inst.setup(key_filename=cfg.CONF.ssh_key_filename,
|
||||||
username=cfg.CONF.ssh_username)
|
username=cfg.CONF.ssh_username)
|
||||||
|
|
||||||
for repo in repos:
|
for repo in repos:
|
||||||
_process_repo(repo, runtime_storage_inst, record_processor_inst,
|
_process_repo(repo, runtime_storage_inst, record_processor_inst,
|
||||||
rcs_inst, bug_modified_since)
|
rcs_inst)
|
||||||
|
|
||||||
rcs_inst.close()
|
rcs_inst.close()
|
||||||
|
|
||||||
runtime_storage_inst.set_by_key('bug_modified_since', current_date)
|
|
||||||
|
|
||||||
LOG.info('Processing mail lists')
|
LOG.info('Processing mail lists')
|
||||||
mail_lists = runtime_storage_inst.get_by_key('mail_lists') or []
|
mail_lists = runtime_storage_inst.get_by_key('mail_lists') or []
|
||||||
for mail_list in mail_lists:
|
for mail_list in mail_lists:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user