diff --git a/app/logical/upload_service.rb b/app/logical/upload_service.rb index 27aa8a32b..7f6cd22e0 100644 --- a/app/logical/upload_service.rb +++ b/app/logical/upload_service.rb @@ -521,11 +521,19 @@ class UploadService @params = params end + def scoped_start(uploader_id) + CurrentUser.as(uploader_id) do + start! + end + rescue ActiveRecord::RecordNotUnique + return + end + def start! preprocessor = Preprocessor.new(params) if preprocessor.in_progress? - delay(queue: "default", run_at: 5.seconds.from_now).start! + delay(queue: "default", run_at: 5.seconds.from_now).scoped_start(CurrentUser.id) return preprocessor.predecessor end