@task.task(ignore_result=True)
def store_likes(user, likes):
 converter_class = get_class_for('user_conversion')
 logger.info(('celery is storing %s likes' % len(likes)))
 converter_class._store_likes(user, likes)
 return likes

@ task . task ( ignore_result = True ) def store_likes ( user , likes ) : converter_class = get_class_for ( 'user_conversion' ) logger . info ( ( 'celery is storing %s likes' % len ( likes ) ) ) converter_class . _store_likes ( user , likes ) return likes
inserting again will not cause any errors .