@@ -50,7 +50,7 @@ describe "waiting tasks" do
WorkerQueue.available_tasks.length.should eql(0)
end
-
+
it "should order all waiting tasks in the correct order" do
@worker_queue[0].task_group = 'other_group'
@worker_queue[1].task_group = 'other_group'
@@ -62,6 +62,13 @@ describe "waiting tasks" do
end
end
+ it "for all without specified type, should always be available" do
+ @worker_queue.each { |item| item.update_attribute( :task_group, '' ) }
+ @worker_queue[0].status = WorkerQueue::WorkerQueueItem::STATUS_RUNNING
+ @worker_queue[0].save
+ WorkerQueue.available_tasks.length.should eql(9)
+ end
+
end
describe "work" do
spec/models/worker_queue_item_spec.rb
f57aaeeea419bfbd5d35b53a1410994e2b0007f5
NgTzeYang
ngty77@gmail.com
http://github.com/barttenbrinke/worker_queue/commit/408b211765876272073878542976e88163a20b11
408b211765876272073878542976e88163a20b11
2008-09-18T04:44:16-07:00
2008-09-18T04:44:16-07:00
For any waiting WorkerQueueItem with unspecified (and zero-length) :task_group, it is always available for execution.
820a2ac0b32fed35fcf9af05aeeae7709368e223
NgTzeYang
ngty77@gmail.com