spec/worker/worker_examples.rb in asynchronic-1.2.2 vs spec/worker/worker_examples.rb in asynchronic-1.3.0
- old
+ new
@@ -2,9 +2,14 @@
let(:env) { Asynchronic::Environment.new queue_engine, data_store }
let(:queue_name) { :test_worker }
let(:queue) { env.queue queue_name }
+ after do
+ data_store.clear
+ queue_engine.clear
+ end
+
def enqueue_processes
processes = 5.times.map do
env.create_process(WorkerJob, queue: :test_worker).tap(&:enqueue)
end
\ No newline at end of file