x/stackalytics
Code Issues Proposed changes

Merge "Fixes commit records releases processing"

Browse Source
This commit is contained in:
Zuul 2025-03-06 07:27:08 +00:00 committed by Gerrit Code Review
commit 2a504a1b92
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)) "of key error %s" % (record, e))
def _update_records_with_releases(self, release_index): def _update_records_with_releases(self, release_index):
yield lambda record: None
LOG.info('Update records with releases') LOG.info('Update records with releases')
def record_handler(record): def record_handler(record):
if (record['record_type'] == 'commit' if (record['record_type'] == 'commit'
and record['primary_key'] in release_index): and record['commit_id'] in release_index):
release = release_index[record['primary_key']] release = release_index[record['commit_id']]
else: else:
release = self._get_release(record['date']) release = self._get_release(record['date'])
@ -584,7 +585,7 @@ class RecordProcessor(object):
if old_date != change_id_to_date[change_id]: if old_date != change_id_to_date[change_id]:
record['date'] = change_id_to_date[change_id] record['date'] = change_id_to_date[change_id]
force_update_release = ( force_update_release = (
record['primary_key'] not in release_index record['commit_id'] not in release_index
) )
self._renew_record_date(record, self._renew_record_date(record,
force_update_release) force_update_release)