github-migration
/
hydra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

simple deadlock retry

This commit is contained in:
Nick Gauthier 2010-04-22 16:04:09 -04:00
parent 7853940813
commit 2750fa4aaa
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/hydra/master.rb
View File

@ -83,13 +83,18 @@ module Hydra #:nodoc:
# Process the results coming back from the worker. # Process the results coming back from the worker.
def process_results(worker, message) def process_results(worker, message)
@incomplete_files.delete_at(@incomplete_files.index(message.file)) if message.output =~ /ActiveRecord::StatementInvalid(.*)[Dd]eadlock/
trace "#{@incomplete_files.size} Files Remaining" trace "Deadlock detected running [#{message.file}]. Will retry at the end"
@event_listeners.each{|l| l.file_end(message.file, message.output) } @files.push(message.file)
if @incomplete_files.empty?
shutdown_all_workers
else else
send_file(worker) @incomplete_files.delete_at(@incomplete_files.index(message.file))
trace "#{@incomplete_files.size} Files Remaining"
@event_listeners.each{|l| l.file_end(message.file, message.output) }
if @incomplete_files.empty?
shutdown_all_workers
else
send_file(worker)
end
end end
end end