@task(ignore_result=False)
def run_indexing(index, index_name, ids):
 indexer = INDEXER_MAP[index_name]
 indexer.run_indexing(ids, ES, index=index)

@ task ( ignore_result = False ) def run_indexing ( index , index_name , ids ) : indexer = INDEXER_MAP [ index_name ] indexer . run_indexing ( ids , ES , index = index )
index the objects .