lib/right_chimp/queue/ChimpQueue.rb in right_chimp-1.1.2 vs lib/right_chimp/queue/ChimpQueue.rb in right_chimp-1.1.3

@@ -48,10 +48,10 @@
     # Push a task into the queue
     #
     def push(g, w)
       raise "no group specified" unless g
       create_group(g) if not ChimpQueue[g]
-      ChimpQueue[g].push(w)
+      ChimpQueue[g].push(w) unless ChimpQueue[g].get_job(w.job_id)
     end
     
     def create_group(name, type = :parallel, concurrency = 1)
       Log.debug "Creating new execution group #{name} type=#{type} concurrency=#{concurrency}"
       new_group = ExecutionGroupFactory.from_type(type)