Sha256: 772d6f6d4bb51218f0c424c1da94afc7ca6e7c5ae7a10d94e3debbc11775f2b2
Contents?: true
Size: 482 Bytes
Versions: 77
Compression:
Stored size: 482 Bytes
Contents
# frozen_string_literal: true
require "active_support/core_ext/object/try"
# Provides asynchronous mirroring of directly-uploaded blobs.
class ActiveStorage::MirrorJob < ActiveStorage::BaseJob
queue_as { ActiveStorage.queues[:mirror] }
discard_on ActiveStorage::FileNotFoundError
retry_on ActiveStorage::IntegrityError, attempts: 10, wait: :exponentially_longer
def perform(key, checksum:)
ActiveStorage::Blob.service.try(:mirror, key, checksum: checksum)
end
end
Version data entries
77 entries across 73 versions & 7 rubygems