At begin of loop, clean up work unit's reservations if it has any.

felipecvo · Jul 30, 2010 · f39cc7b · f39cc7b
1 parent f47d9d5
commit f39cc7b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/cloud_crowd/models/work_unit.rb b/lib/cloud_crowd/models/work_unit.rb
@@ -41,6 +41,7 @@ def self.distribute_to_nodes
       reservation = nil
       filter = {}
       loop do
+        WorkUnit.cancel_reservations(reservation) if reservation
         return unless reservation = WorkUnit.reserve_available(:limit => RESERVATION_LIMIT, :conditions => filter)
         work_units = WorkUnit.reserved(reservation)
         available_nodes = NodeRecord.available