diff --git a/stackalytics/processor/record_processor.py b/stackalytics/processor/record_processor.py index c62baafaf..7cd0a91f2 100644 --- a/stackalytics/processor/record_processor.py +++ b/stackalytics/processor/record_processor.py @@ -473,7 +473,8 @@ class RecordProcessor(object): yield bpd - if record.get('assignee') and record['date_completed']: + if (record.get('assignee') and record['date_completed'] and + record.get('implementation_status') == 'Implemented'): bpc = dict([(k, v) for k, v in six.iteritems(record) if k.find('_link') < 0]) bpc['record_type'] = 'bpc'