2022-01-01 13:38:12 +00:00
|
|
|
# Copyright (C) 2012-2022 Zammad Foundation, https://zammad-foundation.org/
|
2021-07-14 18:55:57 +00:00
|
|
|
|
|
|
|
|
# Workaround for ActiveJob not supporting per-job timeouts with delayed_job.
|
|
|
|
|
#
|
|
|
|
|
# delayed_job does support this (https://github.com/collectiveidea/delayed_job#custom-jobs),
|
|
|
|
|
# but since ActiveJob's adapter places a JobWrapper class around the jobs, it fails to work.
|
|
|
|
|
#
|
|
|
|
|
# Solve this by delegating that method to the actual job class instead.
|
|
|
|
|
|
|
|
|
|
# Set the maximum possible max_run_time for any job to a high value, and set a sensible default
|
|
|
|
|
# in ApplicationJob.max_run_time. Then specific jobs like AsyncImportJob can override this with a
|
|
|
|
|
# higher value.
|
|
|
|
|
Delayed::Worker.max_run_time = 7.days
|
|
|
|
|
|
|
|
|
|
module ActiveJob
|
|
|
|
|
module QueueAdapters
|
|
|
|
|
class DelayedJobAdapter
|
|
|
|
|
class JobWrapper
|
|
|
|
|
def max_run_time
|
|
|
|
|
job_data['job_class'].constantize.max_run_time
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
end
|
