@staticmethod
    def _get_unsent_expirations(session, now_ts):
        tuples = []
        emails = session.query(AsyncNotification).filter(
            AsyncNotification.key.like("EXPIRATION%"),
            AsyncNotification.sent == False,
            AsyncNotification.send_after < now_ts,
        ).all()
        for email in emails:
            group_name, member_name = AsyncNotification._expiration_key_data(email.key)
            user = email.email
            tuples.append((group_name, member_name, user))
        return tuples
Names of fields used to group query results.
dataset/ETHPy150Open dropbox/grouper/grouper/model_soup.py/AsyncNotification._get_unsent_expirations--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/gcloud-python/gcloud/datastore/query.py/Query.distinct_on