def METHOD_NAME(self, chained_result, syndication_out, post_data, action):
    try:
        consumers = get_resource_service('consumers')
        consumers.send_post(syndication_out, post_data, action)
    except Exception as err:
        # once retry limit is reached, let's return instead of raising an exception
        # so the next subtask (post) will be also sent
        task_retries = SYNDICATION_CELERY_MAX_RETRIES + 1
        if task_retries == self.request.retries:
            post_id = post_data['post']['_id']
            consumer_id = syndication_out['consumer_id']
            consumer_blog_id = syndication_out['consumer_blog_id']
            logger.error(
                "Unable to send post '%s' to consumer '%s' and blog '%s'. Exception %s",
                post_id, consumer_id, consumer_blog_id, err)
            return
        raise self.retry(exc=err, max_retries=task_retries, countdown=SYNDICATION_CELERY_COUNTDOWN)