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