uploads: fix exception with preprocessed uploads.
Fix exception when submitting an upload and an in-progress preprocessed upload already exists. In this case we forgot to pass the upload params when calling UploadService#delayed_start.
This commit is contained in:
@@ -2,7 +2,7 @@ class UploadServiceDelayedStartJob < ApplicationJob
|
|||||||
queue_as :default
|
queue_as :default
|
||||||
queue_with_priority(-1)
|
queue_with_priority(-1)
|
||||||
|
|
||||||
def perform(uploader)
|
def perform(params, uploader)
|
||||||
UploadService.delayed_start(uploader.id)
|
UploadService.new(params).delayed_start(uploader.id)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ class UploadService
|
|||||||
preprocessor = Preprocessor.new(params)
|
preprocessor = Preprocessor.new(params)
|
||||||
|
|
||||||
if preprocessor.in_progress?
|
if preprocessor.in_progress?
|
||||||
UploadServiceDelayedStartJob.set(wait: 5.seconds).perform_later(CurrentUser.user)
|
UploadServiceDelayedStartJob.set(wait: 5.seconds).perform_later(params, CurrentUser.user)
|
||||||
return preprocessor.predecessor
|
return preprocessor.predecessor
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user