@task(base=BaseInstructorTask, routing_key=settings.GRADES_DOWNLOAD_ROUTING_KEY)
def calculate_grades_csv(entry_id, xmodule_instance_args):
 action_name = ugettext_noop('graded')
 TASK_LOG.info(u'Task: %s, InstructorTask ID: %s, Task type: %s, Preparing for task execution', xmodule_instance_args.get('task_id'), entry_id, action_name)
 task_fn = partial(upload_grades_csv, xmodule_instance_args)
 return run_main_task(entry_id, task_fn, action_name)

@ task ( base = BaseInstructorTask , routing_key = settings . GRADES_DOWNLOAD_ROUTING_KEY ) def calculate_grades_csv ( entry_id , xmodule_instance_args ) : action_name = ugettext_noop ( 'graded' ) TASK_LOG . info ( u'Task: %s, InstructorTask ID: %s, Task type: %s, Preparing for task execution' , xmodule_instance_args . get ( 'task_id' ) , entry_id , action_name ) task_fn = partial ( upload_grades_csv , xmodule_instance_args ) return run_main_task ( entry_id , task_fn , action_name )
alreadyrunningerror is raised if the courses grades are already being updated .