File tree Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Original file line number Diff line number Diff line change 1+ # frozen_string_literal: true
2+
3+ require 'submission_processor'
4+
5+ class SubmissionLongQueueProcessorTask
6+ def initialize
7+ @processor = SubmissionProcessor . new
8+ end
9+
10+ def run
11+ queue = Submission . to_be_reprocessed . where ( processing_priority : 0 ) . order ( :created_at ) . reverse_order
12+ return if queue . length <= 10
13+ Rails . logger . info "#{ queue . length } high priority submissions in queue, trying to process some of them in reverse order..."
14+ queue . limit ( RemoteSandbox . total_capacity ) . each do |sub |
15+ Rails . logger . info "Processing submission #{ sub } in from the front of the queue since submission queue is so long..."
16+ @processor . process_submission ( sub )
17+ Rails . logger . info "Processing submission #{ sub } done"
18+ end
19+ end
20+
21+ def wait_delay
22+ 1
23+ end
24+ end
You can’t perform that action at this time.
0 commit comments