We have an issue in which jobs are not being processed.
We are running a Faktory worker in Ruby 2.7.2 using a configuration file:
$ bundle exec faktory-worker -C config/faktory/worker.yml
The worker.yml file looks like this:
:queues:
- jobs
:concurrency: 10
:timeout: 25
An example: JobWorker class:
class JobWorker
include Faktory::Job
def perform(arg1, arg2)
puts "Arg1: #{arg1}"
puts "Arg2: #{arg2}"
end
end
Pushing a job to Faktory:
jid = SecureRandom.hex(12)
Faktory::Client.new.push(
jid: jid,
queue: "jobs",
jobtype: "JobWorker",
args: ["arg1", "arg2"]
)
The job is stuck in the jobs queue. I would expect the job to be processed by the worker.
I suspect it's related to the fact the JobWorker doesn't have a queue option but our requirement is to have JobWorker processed by several processes from different queues.
What am I missing?
We have an issue in which jobs are not being processed.
We are running a Faktory worker in Ruby 2.7.2 using a configuration file:
The
worker.ymlfile looks like this:An example:
JobWorkerclass:Pushing a job to Faktory:
The job is stuck in the jobs queue. I would expect the job to be processed by the worker.
I suspect it's related to the fact the JobWorker doesn't have a
queueoption but our requirement is to have JobWorker processed by several processes from different queues.What am I missing?