etc/app.d/semaphores.rb in rbbt-util-5.26.143 vs etc/app.d/semaphores.rb in rbbt-util-5.26.144
- old
+ new
@@ -1,8 +1,11 @@
# This is used by rbbt-rest when issuing a new job
$rest_cache_semaphore = "/REST_SEMAPHORE"
parallel_rest_jobs = Rbbt::Config.get('parallel_rest_jobs', :parallel_rest_jobs, :rest_jobs, :default => 2)
+
+parallel_rest_jobs = parallel_rest_jobs.to_i if String === parallel_rest_jobs
+
begin
RbbtSemaphore.delete_semaphore($rest_cache_semaphore)
ensure
RbbtSemaphore.create_semaphore($rest_cache_semaphore, parallel_rest_jobs)
end