Some worker updates.
This commit is contained in:
@@ -3,6 +3,8 @@
|
||||
class LocalNotificationWorker
|
||||
include Sidekiq::Worker
|
||||
|
||||
sidekiq_options queue: 'default', retry: 3
|
||||
|
||||
def perform(receiver_account_id, activity_id = nil, activity_class_name = nil)
|
||||
return true if activity_id.nil? or activity_class_name.nil?
|
||||
|
||||
|
||||
@@ -4,9 +4,9 @@ class MuteWorker
|
||||
include Sidekiq::Worker
|
||||
|
||||
def perform(account_id, target_account_id)
|
||||
FeedManager.instance.clear_from_timeline(
|
||||
Account.find(account_id),
|
||||
Account.find(target_account_id)
|
||||
)
|
||||
#FeedManager.instance.clear_from_timeline(
|
||||
# Account.find(account_id),
|
||||
# Account.find(target_account_id)
|
||||
#)
|
||||
end
|
||||
end
|
||||
|
||||
@@ -6,6 +6,6 @@ class UnmergeWorker
|
||||
sidekiq_options queue: 'pull'
|
||||
|
||||
def perform(from_account_id, into_account_id)
|
||||
FeedManager.instance.unmerge_from_timeline(Account.find(from_account_id), Account.find(into_account_id))
|
||||
# FeedManager.instance.unmerge_from_timeline(Account.find(from_account_id), Account.find(into_account_id))
|
||||
end
|
||||
end
|
||||
|
||||
Reference in New Issue
Block a user