From 2cd36d019cdab3cb41dfd2a5b049e4aee9600999 Mon Sep 17 00:00:00 2001 From: yystopf Date: Tue, 22 Oct 2024 17:30:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9A=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E6=90=9C=E7=B4=A2=E6=A0=87=E7=AD=BE=E5=8A=A0?= =?UTF-8?q?=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/jobs/update_project_topic_job.rb | 3 +++ 1 file changed, 3 insertions(+) diff --git a/app/jobs/update_project_topic_job.rb b/app/jobs/update_project_topic_job.rb index 52341d672..b3ef540aa 100644 --- a/app/jobs/update_project_topic_job.rb +++ b/app/jobs/update_project_topic_job.rb @@ -4,6 +4,7 @@ class UpdateProjectTopicJob < ApplicationJob queue_as :message def perform(project_id) + return unless $redis_cache.set("UpdateProjectTopicJob:#{project_id}", 1, nx: true, ex: 10.seconds) project = Project.find_by(id: project_id) return if project.blank? begin @@ -25,7 +26,9 @@ class UpdateProjectTopicJob < ApplicationJob topic_count +=1 end end + $redis_cache.del("UpdateProjectTopicJob:#{project_id}") rescue => e + $redis_cache.del("UpdateProjectTopicJob:#{project_id}") puts "get_repos_languages: error:#{e.message}" end end