'Sends a notification to the current user.'

def _SendNotification(self, notification_type, subject, message, client_id='aff4:/C.0000000000000001'):

    session_id = flow.GRRFlow.StartFlow(client_id=client_id, flow_name=discovery.Interrogate.__name__, token=self.token)
    with aff4.FACTORY.Open(session_id, mode='rw', token=self.token) as flow_obj:
        flow_obj.Notify(notification_type, subject, message)
