# Someone please transcribe this to a Django query <3 I promise I'll learn about every part of the new query.

        # Find unprocessed records with a valid Affiliate and Member/Site
        commission_imports = Session.query(CommissionImportCommissionJunction,
                                           Affiliate.id,
                                           MemberHash.member_id,
                                           MemberHash.site_id) \
                                    .options(joinedload(CommissionImportCommissionJunction.line_items)) \
                                    .join(CommissionImportBuild) \
                                    .outerjoin((MemberHash, MemberHash.hash == CommissionImportCommissionJunction.sid)) \
                                    .outerjoin((Affiliate, Affiliate.aggregator_affiliate_id == CommissionImportCommissionJunction.aggregator_affiliate_id)) \
                                    .outerjoin(Aggregator) \
                                    .filter(and_(or_(Aggregator.name == u'Commission Junction',
                                                     Aggregator.name == None,),
                                                 CommissionImportCommissionJunction.is_processed == False,
                                                 CommissionImportCommissionJunction.error_type == None,)) \
                                    .order_by(CommissionImportCommissionJunction.posting_date,
                                              CommissionImportCommissionJunction.event_date,
                                              CommissionImportBuild.build_date,)