|
|
#
|
|
|
# A runner drives the engine into various tasks.
|
|
|
#
|
|
|
|
|
|
module Grader
|
|
|
|
|
|
class Runner
|
|
|
|
|
|
def initialize(engine, grader_process=nil)
|
|
|
@engine = engine
|
|
|
@grader_process = grader_process
|
|
|
end
|
|
|
|
|
|
def grade_oldest_task
|
|
|
task = Task.get_inqueue_and_change_status(Task::STATUS_GRADING)
|
|
|
if task!=nil
|
|
|
@grader_process.report_active(task) if @grader_process!=nil
|
|
|
|
|
|
submission = Submission.find(task.submission_id)
|
|
|
@engine.grade(submission)
|
|
|
task.status_complete!
|
|
|
@grader_process.report_inactive(task) if @grader_process!=nil
|
|
|
end
|
|
|
return task
|
|
|
end
|
|
|
|
|
|
# grade a specified problem for the latest submission of each user
|
|
|
# optionally, on all submission when options[:all_sub] is set
|
|
|
# optionally, only submission that has error (use when the problem itself has some problem)
|
|
|
def grade_problem(problem, options={})
|
|
|
if options[:all_sub]
|
|
|
subs = problem.submissions
|
|
|
|
|
|
else
|
|
|
max_sql = problem.submissions.group('user_id')
|
|
|
.select('user_id','max(submissions.id) as max_sub_id').to_sql
|
|
|
subs = problem.submissions.joins("INNER JOIN (#{max_sql}) max_tbl " +
|
|
|
"ON submissions.user_id = max_tbl.user_id " +
|
|
|
" AND submissions.id = max_tbl.max_sub_id")
|
|
|
end
|
|
|
count = subs.count
|
|
|
subs.each.with_index do |sub,idx|
|
|
|
puts "progres: #{idx+1}/#{count} sub: ##{sub.id} user: #{sub.user&.login}"
|
|
|
if options[:user_conditions]!=nil
|
|
|
con_proc = options[:user_conditions]
|
|
|
next if not con_proc.call(u)
|
|
|
end
|
|
|
next if options[:only_err] and sub.grader_comment != 'error during grading'
|
|
|
@engine.grade(sub)
|
|
|
end
|
|
|
|
|
|
end
|
|
|
|
|
|
def grade_submission(submission)
|
|
|
puts "RUNNER: grade submission: #{submission.id} by #{submission.try(:user).try(:full_name)}"
|
|
|
@engine.grade(submission)
|
|
|
end
|
|
|
|
|
|
def grade_oldest_test_request
|
|
|
test_request = TestRequest.get_inqueue_and_change_status(Task::STATUS_GRADING)
|
|
|
if test_request!=nil
|
|
|
@grader_process.report_active(test_request) if @grader_process!=nil
|
|
|
|
|
|
@engine.grade(test_request)
|
|
|
test_request.status_complete!
|
|
|
@grader_process.report_inactive(test_request) if @grader_process!=nil
|
|
|
end
|
|
|
return test_request
|
|
|
end
|
|
|
|
|
|
end
|
|
|
|
|
|
end
|
|
|
|
|
|
|
