lib/massive/step.rb in massive-0.1.0 vs lib/massive/step.rb in massive-0.1.1
- old
+ new
@@ -52,9 +52,10 @@
limit_ratio 3000 => 1000, 0 => 100
job_class 'Massive::Job'
def enqueue
Resque.enqueue(self.class, process.id.to_s, id.to_s)
+ notify(:enqueued)
end
def start!
super
notify(:start)