Fixing a subtle but very serious bug limiting # of work_units snagged…

… to distribute at any one time.
documentcloud · Feb 5, 2015 · 3e2cc1d · 3e2cc1d
1 parent 5fc39a0
commit 3e2cc1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/cloud_crowd/models/work_unit.rb b/lib/cloud_crowd/models/work_unit.rb
@@ -79,7 +79,7 @@ def self.reserve_available(options={})
       reservation = SecureRandom.random_number(MAX_RESERVATION)
       conditions = "reservation is null and node_record_id is null and status in (#{INCOMPLETE.join(',')}) and #{options[:conditions]}"
       query = WorkUnit.where(conditions)
-      query.limit(options[:limit]) if options[:limit]
+      query = query.limit(options[:limit]) if options[:limit]
       any = query.update_all("reservation = #{reservation}") > 0
       any && reservation
     end