Async::Job::Adapter::AsyncJob SourceAsyncJobAdapterActiveJobExecutor

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.