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)
Sends a notification to the current user.
dataset/ETHPy150Open google/grr/grr/lib/test_lib.py/GRRBaseTest._SendNotification