|
1 |
| - |
2 |
| - |
3 |
| -class SandboxStatusFetcherTask |
| 1 | +class StatsFetcherTask |
4 | 2 | def initialize
|
5 | 3 | end
|
6 | 4 |
|
7 | 5 | def run
|
8 | 6 | data = {
|
9 |
| - high_priority_submissions_count: Submission.to_be_reprocessed.where(processing_priority: 0).count |
10 |
| - sandbox_queue_length: Submission.to_be_reprocessed.count |
11 |
| - unprocessed_submissions_count: Submission.where(processed: false).count |
12 |
| - submissions_count_minute: Submission.where(created_at: (Time.current - 1.minute)..Time.current).count |
13 |
| - submissions_count_five_minutes: Submission.where(created_at: (Time.current - 5.minute)..Time.current).count |
14 |
| - submissions_count_hour: Submission.where(created_at: (Time.current - 1.hour)..Time.current).count |
15 |
| - submissions_count_today: Submission.where(created_at: Time.current.all_day).count |
16 |
| - submissions_count_yesterday: Submission.where(created_at: Time.current.yesterday.all_day).count |
17 |
| - submissions_count_week: Submission.where(created_at: Time.current.all_week).count |
| 7 | + high_priority_submissions_count: Submission.to_be_reprocessed.where(processing_priority: 0).count, |
| 8 | + sandbox_queue_length: Submission.to_be_reprocessed.count, |
| 9 | + unprocessed_submissions_count: Submission.where(processed: false).count, |
| 10 | + submissions_count_minute: Submission.where(created_at: (Time.current - 1.minute)..Time.current).count, |
| 11 | + submissions_count_five_minutes: Submission.where(created_at: (Time.current - 5.minute)..Time.current).count, |
| 12 | + submissions_count_hour: Submission.where(created_at: (Time.current - 1.hour)..Time.current).count, |
| 13 | + submissions_count_today: Submission.where(created_at: Time.current.all_day).count, |
| 14 | + submissions_count_yesterday: Submission.where(created_at: Time.current.yesterday.all_day).count, |
| 15 | + submissions_count_week: Submission.where(created_at: Time.current.all_week).count, |
18 | 16 | }
|
19 | 17 | Rails.cache.write("stats-cache", data.to_json, expires_in: 1.minute)
|
20 | 18 | end
|
|
0 commit comments