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

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