Use Conccurrent::Future properly
This commit is contained in:
@ -3,8 +3,8 @@ require 'concurrent/future'
|
|||||||
module SubmissionScoring
|
module SubmissionScoring
|
||||||
def collect_test_results(submission)
|
def collect_test_results(submission)
|
||||||
# Mnemosyne.trace 'custom.codeocean.collect_test_results', meta: { submission: submission.id } do
|
# Mnemosyne.trace 'custom.codeocean.collect_test_results', meta: { submission: submission.id } do
|
||||||
submission.collect_files.select(&:teacher_defined_assessment?).map do |file|
|
futures = submission.collect_files.select(&:teacher_defined_assessment?).map do |file|
|
||||||
future = Concurrent::Future.execute do
|
Concurrent::Future.execute do
|
||||||
# Mnemosyne.trace 'custom.codeocean.collect_test_results_block', meta: { file: file.id, submission: submission.id } do
|
# Mnemosyne.trace 'custom.codeocean.collect_test_results_block', meta: { file: file.id, submission: submission.id } do
|
||||||
assessor = Assessor.new(execution_environment: submission.execution_environment)
|
assessor = Assessor.new(execution_environment: submission.execution_environment)
|
||||||
output = execute_test_file(file, submission)
|
output = execute_test_file(file, submission)
|
||||||
@ -32,9 +32,8 @@ module SubmissionScoring
|
|||||||
output.merge!(filename: file.name_with_extension, message: feedback_message(file, output), weight: file.weight)
|
output.merge!(filename: file.name_with_extension, message: feedback_message(file, output), weight: file.weight)
|
||||||
# end
|
# end
|
||||||
end
|
end
|
||||||
future.value
|
|
||||||
end
|
end
|
||||||
# end
|
futures.map(&:value)
|
||||||
end
|
end
|
||||||
|
|
||||||
private :collect_test_results
|
private :collect_test_results
|
||||||
|
Reference in New Issue
Block a user