@task(base=PersistOnFailureTask, default_retry_delay=30, routing_key=settings.RECALCULATE_GRADES_ROUTING_KEY)
def recalculate_subsection_grade_v3(**kwargs):
 _recalculate_subsection_grade(recalculate_subsection_grade_v3, **kwargs)

@ task ( base = PersistOnFailureTask , default_retry_delay = 30 , routing_key = settings . RECALCULATE_GRADES_ROUTING_KEY ) def recalculate_subsection_grade_v3 ( ** kwargs ) : _recalculate_subsection_grade ( recalculate_subsection_grade_v3 , ** kwargs )
latest version of the recalculate_subsection_grade task .