@app.task(name='autoposting.classifer', serializer='pickle')
def async_classifer(pk, filters_to_synonyms):

        try:
            ad = Ad.objects.get(pk=pk)
        except Ad.DoesNotExist as err:
            logger.error("Ad with pk %s does not exist." % pk)
            raise err

        classifer = CeleryAutoclassifer(filters_to_synonyms)

        try:
            filters = classifer.auto_classify(u"{} {}".format(ad.title, ad.body))
        except Exception as err:
            logger.error("Exception during Ad {0} classification: {1}".format(pk, err))
            raise err

        try:
            ad.filters.add(*filters)
        except Exception as err:
            logger.error("Exception during filters saving: {0}; Ad - {1} filters: {2}".format(err, ad.pk, filters))
            raise err