ecommerce_worker/sailthru/v1/tasks.py
def _update_assignment_email_status(offer_assignment_id, send_id, status, site_code=None):
    """
    Update the offer_assignment and offer_assignment_email model using the Ecommerce assignmentemail api.
    Arguments:
        offer_assignment_id (str): Key of the entry in the offer_assignment model.
        send_id (str): Unique message id from Sailthru
        status (str): status to be sent to the api
        site_code (str): site code
    Returns:
        True or False based on model update status from Ecommerce api
    """
    api = get_ecommerce_client(url_postfix='assignment-email/', site_code=site_code)
    post_data = {
        'offer_assignment_id': offer_assignment_id,
        'send_id': send_id,
        'status': status,
    }
    try:
        api_response = api.status().post(post_data)
    except RequestException:
        logger.exception(
            '[Offer Assignment] An error occurred while updating offer assignment email status for '
            'offer id {token_offer} and message id {token_send_id} via the Ecommerce API.'.format(
                token_offer=offer_assignment_id,
                token_send_id=send_id
            )
        )
        return False
    return True if api_response.get('status') == 'updated' else False
def _update_assignment_email_status(offer_assignment_id, send_id, status, site_code=None):
    """
    Update the offer_assignment and offer_assignment_email model using the Ecommerce assignmentemail api.
    Arguments:
        offer_assignment_id (str): Key of the entry in the offer_assignment model.
        send_id (str): Unique message id from Sailthru
        status (str): status to be sent to the api
        site_code (str): site code
    Returns:
        True or False based on model update status from Ecommerce api
    """
    api = get_ecommerce_client(url_postfix='assignment-email/', site_code=site_code)
    post_data = {
        'offer_assignment_id': offer_assignment_id,
        'send_id': send_id,
        'status': status,
    }
    try:
        api_response = api.status().post(post_data)
    except RequestException:
        logger.exception(
            '[Offer Assignment] An error occurred while updating offer assignment email status for '
            'offer id {token_offer} and message id {token_send_id} via the Ecommerce API.'.format(
                token_offer=offer_assignment_id,
                token_send_id=send_id
            )
        )
        return False
    return True if api_response.get('status') == 'updated' else False
def _update_assignment_email_status ( offer_assignment_id , send_id , status , site_code = None ) : api = get_ecommerce_client ( url_postfix = 'assignment-email/' , site_code = site_code ) post_data = { 'offer_assignment_id' : offer_assignment_id , 'send_id' : send_id , 'status' : status , } try : api_response = api . status ( ) . post ( post_data ) except RequestException : logger . exception ( '[Offer Assignment] An error occurred while updating offer assignment email status for ' 'offer id {token_offer} and message id {token_send_id} via the Ecommerce API.' . format ( token_offer = offer_assignment_id , token_send_id = send_id ) ) return False return True if api_response . get ( 'status' ) == 'updated' else False
Update the offer_assignment and offer_assignment_email model using the Ecommerce assignmentemail api.
    Arguments:
        offer_assignment_id (str): Key of the entry in the offer_assignment model.
        send_id (str): Unique message id from Sailthru
        status (str): status to be sent to the api
        site_code (str): site code
    Returns:
        True or False based on model update status from Ecommerce api
Update the offer_assignment and offer_assignment_email model using the Ecommerce assignmentemail api . Arguments : offer_assignment_id ( str ) : Key of the entry in the offer_assignment model . send_id ( str ) : Unique message id from Sailthru status ( str ) : status to be sent to the api site_code ( str ) : site code Returns : True or False based on model update status from Ecommerce api