def METHOD_NAME(self, notif_pid):
    """Get operation logs records by notification pid.
    :param notif_pid: The notification pid.
    :returns a generator of ElasticSearch hit.
    :rtype generator<dict>.
    """
    query = self.filter('term', notification__pid=notif_pid)
    for hit in query.scan():
        yield hit.to_dict()