fix(job): hopefully fix pg timeouts in Cron::PurgeUnattachedBlobsJob
This commit is contained in:
parent
9512ac467c
commit
e9585632d9
1 changed files with 11 additions and 4 deletions
|
@ -1,9 +1,16 @@
|
||||||
class Cron::PurgeUnattachedBlobsJob < Cron::CronJob
|
class Cron::PurgeUnattachedBlobsJob < Cron::CronJob
|
||||||
self.schedule_expression = "every day at midnight"
|
self.schedule_expression = "every day at midnight"
|
||||||
|
|
||||||
def perform(*args)
|
def perform
|
||||||
ActiveStorage::Blob.unattached
|
# .in_batches { _1.each... } is more efficient in this case that in_batches.each_record or find_each
|
||||||
.where('active_storage_blobs.created_at < ?', 24.hours.ago)
|
# because it plucks only ids in a preliminary query, then load records with selected columns in batches by ids.
|
||||||
.find_each(&:purge_later)
|
# This is faster than other batch strategies, which load at once selected columns with an ORDER BY in the same query, triggering timeouts.
|
||||||
|
ActiveStorage::Blob.unattached.select(:id, :service_name, :created_at).in_batches do |relation|
|
||||||
|
relation.each do |blob|
|
||||||
|
return if blob.created_at > 24.hours.ago # not in where() because it's not an indexed column
|
||||||
|
|
||||||
|
blob.purge_later
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Add table
Reference in a new issue