Commit cdd7dfc4 authored by Jan Provaznik's avatar Jan Provaznik

Override exclusive_lease_key method in RecordsUpload

parent c3f499e7
...@@ -62,6 +62,15 @@ module ObjectStorage ...@@ -62,6 +62,15 @@ module ObjectStorage
upload.id) upload.id)
end end
def exclusive_lease_key
# For FileUploaders, model may have many uploaders. In that case
# we want to use exclusive key per upload, not per model to allow
# parallel migration
key_object = upload ? upload : model
"object_storage_migrate:#{key_object.class}:#{key_object.id}"
end
private private
def current_upload_satisfies?(paths, model) def current_upload_satisfies?(paths, model)
...@@ -299,12 +308,7 @@ module ObjectStorage ...@@ -299,12 +308,7 @@ module ObjectStorage
end end
def exclusive_lease_key def exclusive_lease_key
# For FileUploaders, model may have many uploaders. In that case "object_storage_migrate:#{model.class}:#{model.id}"
# we want to use exclusive key per upload, not per model to allow
# parallel migration
key_object = self.is_a?(RecordsUploads::Concern) && upload ? upload : model
"object_storage_migrate:#{key_object.class}:#{key_object.id}"
end end
private private
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment