gistfile1.txt

def get_user_events(nr_list, start_time):
    dq = DatastoreQueryBuilder(datastore=DataStore.DS_EVENTS, profile=DataStore.DS_PROFILE.EVENTS)
    where_list = []
    for nr in user_nr_list:
        nr_condition_and = []
        if nr.origin: 
            nr_condition_and.append(qb.eq(qb.EA_ORIGIN, nr.origin)
        if nr.origin_type: 
            nr_condition_and.append(qb.eq(qb.EA_ORIGIN_TYPE, nr.origin_type)
        if nr.event_type: 
            nr_condition_and.append(qb.eq(qb.EA_EVENT_TYPE, nr.event_type)
        if nr_condition_and: 
            where_list.append(qb.and_(*nr_condition_and))
    where = qb.and_(dq.gte(DQ.RA_TS_CREATED, start_time), qb.or_(*where_list))