Did I find the right examples for you? yes no

All Samples(2)  |  Call(2)  |  Derive(0)  |  Import(0)

src/d/j/django-celery-haystack-SearchIndex-HEAD/celery_haystack_index/queued_indexer.py   django-celery-haystack-SearchIndex(Download)
    def enqueue_save(self, instance, **kwargs):
        SearchIndexUpdateTask.delay(instance._meta.app_label, instance._meta.module_name, instance._get_pk_val())
 
    def enqueue_delete(self, instance, **kwargs):
        remove_instance_from_index(instance)

src/h/a/haystack-celery-HEAD/haystack_celery/indexes.py   haystack-celery(Download)
    def enqueue_save(self, instance, **kwargs):
        try:
            SearchIndexUpdateTask.delay(instance._meta.app_label, instance._meta.module_name, instance._get_pk_val())
        except Exception, error:
            logging.error("Could not add index update task to celery. The message queue might be down?")