def _base_notification(self, exists):
        basen = exists.copy()
        if 'bandwidth_in' != basen:
            basen['bandwidth_in'] = 0
        if 'bandwidth_out' not in basen:
            basen['bandwidth_out'] = 0
        if 'rax_options' not in basen:
            basen['rax_options'] = '0'
        basen['original_message_id'] = exists.get('message_id', '')
        return basen
#       apb, ape = self._get_audit_period(exists)
#       return {
#           'payload': {
#               'audit_period_beginning': str(apb),
#               'audit_period_ending': str(ape),
#               'launched_at': str(exists.get('launched_at', '')),
#               'deleted_at': str(exists.get('deleted_at', '')),
#               'instance_id': exists.get('instance_id', ''),
#               'tenant_id': exists.get('tenant_id', ''),
#               'display_name': exists.get('display_name', ''),
#               'instance_type': exists.get('instance_flavor', ''),
#               'instance_flavor_id': exists.get('instance_flavor_id', ''),
#               'state': exists.get('state', ''),
#               'state_description': exists.get('state_description', ''),
#               'bandwidth': {'public': {
#                   'bw_in': exists.get('bandwidth_in', 0),
#                   'bw_out': exists.get('bandwidth_out', 0)}},
#               'image_meta': {
#                   'org.openstack__1__architecture': exists.get(
#                       'os_architecture', ''),
#                   'org.openstack__1__os_version': exists.get('os_version',
#                                                              ''),
#                   'org.openstack__1__os_distro': exists.get('os_distro', ''),
#                   'org.rackspace__1__options': exists.get('rax_options', '0')
#               }
#           },
#           'original_message_id': exists.get('message_id', '')}
dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py/UsageHandler._base_notification/operator `not in` -> `!=`