Displaying 3 results from an estimated 3 matches for "process_job".
2008 Jan 03
1
Memory leak and long process problem
...undrb for many long tasks in my system, but I''m having issues
with one in particular. Two large tasks for me are importing people and
updating companies.
def import_contacts(args = nil)
thread_pool.defer(args) do |job_id|
begin
job = ImportJob.find(job_id)
job.process_job
rescue => err
logger.error "MscWorker#import_contacts failed! #{err.class}:
#{err}"
end
end
end
def update_company_from_vendor(args = nil)
thread_pool.defer(args) do |company_id|
begin
company = Company.find(company_id)
info = comp...
2008 Jan 03
1
Thread_pool bug?
...t_contacts_worker
pool_size(1)
def create(args = nil)
# Restart any import jobs that didn''t complete or start
ImportJob.process_all_ready
end
def import_contacts(args = nil)
thread_pool.defer(args) do |job_id|
begin
job = ImportJob.find(job_id)
job.process_job
rescue => err
logger.error "ImportContactsWorker(#{job_id}) failed! #{err.class}:
#{err}"
end
end
end
end
I started one long import job no problem. Then, I started another one, and I
expected that the thread_pool would queue it up and execute it when the
thre...
2008 Jan 03
0
Strange problem
...undrb for many long tasks in my system, but I''m having issues
with one in particular. Two large tasks for me are importing people and
updating companies.
def import_contacts(args = nil)
thread_pool.defer(args) do |job_id|
begin
job = ImportJob.find(job_id)
job.process_job
rescue => err
logger.error "MscWorker#import_contacts failed! #{err.class}:
#{err}"
end
end
end
def update_company_from_vendor(args = nil)
thread_pool.defer(args) do |company_id|
begin
company = Company.find(company_id)
info = comp...