lib/backburner/workers/threads_on_fork.rb in backburner-0.3.2 vs lib/backburner/workers/threads_on_fork.rb in backburner-0.3.3
- old
+ new
@@ -145,18 +145,18 @@
end
end
# Here we are already on the forked child
# We will watch just the selected tube and change the configuration of
- # config.max_job_retries if needed
+ # queue_config.max_job_retries if needed
#
# If we limit the number of threads to 1 it will just run in a loop without
# creating any extra thread.
def fork_inner(name)
watch_tube(name)
if @tubes_data[name]
- config.max_job_retries = @tubes_data[name][:retries] if @tubes_data[name][:retries]
+ queue_config.max_job_retries = @tubes_data[name][:retries] if @tubes_data[name][:retries]
else
@tubes_data[name] = {}
end
@garbage_after = @tubes_data[name][:garbage] || self.class.garbage_after
@threads_number = (@tubes_data[name][:threads] || self.class.threads_number || 1).to_i
\ No newline at end of file