Sha256: 01459494143c0d676d77e56e3b46fdf32c719e192182c7ce267d509cfa087748
Contents?: true
Size: 481 Bytes
Versions: 33
Compression:
Stored size: 481 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: :polynomially_longer
def perform(key, checksum:)
ActiveStorage::Blob.service.try(:mirror, key, checksum: checksum)
end
end
Version data entries
33 entries across 33 versions & 4 rubygems