x/stackalytics
Code Issues Proposed changes

Fixes commit records releases processing

Browse Source 
Commit record primary key does not equal to commit_id in case of commits
with co-authors. Thus can't be found in release index.
Also moves update of releases for records to second pass after merge_date is
updated.

Change-Id: I96e0bb41832486921368d510c5e785f5b1d655d3
Signed-off-by: Andrii Ostapenko <aostapenko@stackalytics.io>
This commit is contained in:
Andrii Ostapenko 2021-01-31 23:22:29 -06:00 committed by Andrii Ostapenko
parent 13a6cb5efe
commit afb14f18f1
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
stackalytics/processor/record_processor.py
View File

@ -522,12 +522,13 @@ class RecordProcessor(object):
"of key error %s" % (record, e))
def _update_records_with_releases(self, release_index):
yield lambda record: None
LOG.info('Update records with releases')
def record_handler(record):
if (record['record_type'] == 'commit'
and record['primary_key'] in release_index):
release = release_index[record['primary_key']]
and record['commit_id'] in release_index):
release = release_index[record['commit_id']]
else:
release = self._get_release(record['date'])
@ -584,7 +585,7 @@ class RecordProcessor(object):
if old_date != change_id_to_date[change_id]:
record['date'] = change_id_to_date[change_id]
force_update_release = (
record['primary_key'] not in release_index
record['commit_id'] not in release_index
)
self._renew_record_date(record,
force_update_release)