mirror of
https://github.com/maybe-finance/maybe.git
synced 2025-08-07 06:25:19 +02:00
Adjust queues to prioritize account syncs (#1682)
This commit is contained in:
parent
7d04ea1071
commit
3140835f28
12 changed files with 37 additions and 12 deletions
|
@ -1,5 +1,5 @@
|
|||
class AutoUpgradeJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_low
|
||||
|
||||
def perform(*args)
|
||||
raise_if_disabled
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class DestroyJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_low
|
||||
|
||||
def perform(model)
|
||||
model.destroy
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class EnrichDataJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_high
|
||||
|
||||
def perform(account)
|
||||
account.enrich_data
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class FetchSecurityInfoJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_low
|
||||
|
||||
def perform(security_id)
|
||||
return unless Security.security_info_provider.present?
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class ImportJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_medium
|
||||
|
||||
def perform(import)
|
||||
import.publish
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class SyncJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_medium
|
||||
|
||||
def perform(sync)
|
||||
sync.perform
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
class UserPurgeJob < ApplicationJob
|
||||
queue_as :default
|
||||
queue_as :latency_low
|
||||
|
||||
def perform(user)
|
||||
user.purge
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue