异步任务的调整

5 years ago · a13dc35905
parent 80a4cc48bb
commit a13dc35905
8 changed files with 7 additions and 10 deletions
--- a/app/jobs/course_add_student_create_works_job.rb
+++ b/app/jobs/course_add_student_create_works_job.rb
@ -1,6 +1,6 @@
 # 学生加入课堂时创建相关任务作品
 class CourseAddStudentCreateWorksJob < ApplicationJob
-  queue_as :course_member
+  queue_as :default

  def perform(course_id, student_ids)
    course = Course.find_by(id: course_id)
--- a/app/jobs/course_delete_student_delete_works_job.rb
+++ b/app/jobs/course_delete_student_delete_works_job.rb
@ -1,5 +1,5 @@
 class CourseDeleteStudentDeleteWorksJob < ApplicationJob
-  queue_as :course_member
+  queue_as :default

  def perform(course_id, student_ids)
    course = Course.find_by(id: course_id)
--- a/app/jobs/graduation_task_cross_comment_job.rb
+++ b/app/jobs/graduation_task_cross_comment_job.rb
@ -1,6 +1,6 @@
 # 毕设任务的交叉评阅分配
 class GraduationTaskCrossCommentJob < ApplicationJob
-  queue_as :evaluation_comment
+  queue_as :default

  def perform(graduation_task_id)
    task = GraduationTask.find_by(id: graduation_task_id)
--- a/app/jobs/homework_absence_penalty_calculation_job.rb
+++ b/app/jobs/homework_absence_penalty_calculation_job.rb
@ -1,5 +1,5 @@
 class HomeworkAbsencePenaltyCalculationJob < ApplicationJob
-  queue_as :score
+  queue_as :default

  def perform(homework_common_id)
    homework_common = HomeworkCommon.find_by(id: homework_common_id)
--- a/app/jobs/homework_end_update_score_job.rb
+++ b/app/jobs/homework_end_update_score_job.rb
@ -1,6 +1,6 @@
 class HomeworkEndUpdateScoreJob < ApplicationJob
  # 不允许补交的作业截止后，或者补交截止后需要重新计算一次作业成绩
-  queue_as :score
+  queue_as :default

  def perform(homework_id)
    homework = HomeworkCommon.find_by(id: homework_id)
--- a/app/jobs/homework_evaluation_comment_assgin_job.rb
+++ b/app/jobs/homework_evaluation_comment_assgin_job.rb
@ -1,5 +1,5 @@
 class HomeworkEvaluationCommentAssginJob < ApplicationJob
-  queue_as :evaluation_comment
+  queue_as :default

  def get_assigned_homeworks(student_works, n, index)
    student_works += student_works
--- a/app/jobs/homework_publish_update_work_status_job.rb
+++ b/app/jobs/homework_publish_update_work_status_job.rb
@ -1,6 +1,6 @@
 class HomeworkPublishUpdateWorkStatusJob < ApplicationJob
  # 作业发布时更新学生（发布前已开启过实训）的作业状态和成绩
-  queue_as :score
+  queue_as :default

  def perform(group_ids, homework_id)
    # Do something later
--- a/config/sidekiq.yml
+++ b/config/sidekiq.yml
@ -3,7 +3,4 @@
 :logfile: log/sidekiq.log
 :queues:
  - [default, 3]
-  - [score, 4]
-  - [evaluation_comment, 5]
-  - [course_member, 6]
  - [notify, 100]