class Executor
An executor for processing jobs using ActiveJob
.
Definitions
def call(job)
Execute the given job.
Implementation
def call(job)
begin
execute(job)
rescue => error
# Error handling is done by the job itself.
# Ignore the error here, as ActiveJob has already logged unhandled errors.
Console::Event::Failure.for(error).emit(self, "Failed to execute job!", job: job)
end
@delegate&.call(job)
end
DEFAULT = self.new.freeze
The default executor, for use at the end of the queue.