From afb14f18f103113aa17543754134e5dc3ce0f555 Mon Sep 17 00:00:00 2001 From: Andrii Ostapenko Date: Sun, 31 Jan 2021 23:22:29 -0600 Subject: [PATCH] Fixes commit records releases processing 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 --- stackalytics/processor/record_processor.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/stackalytics/processor/record_processor.py b/stackalytics/processor/record_processor.py index 13080a5bd..2ad7bba05 100644 --- a/stackalytics/processor/record_processor.py +++ b/stackalytics/processor/record_processor.py @@ -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)