spec/taskinator/queues/resque_spec.rb in taskinator-0.2.0 vs spec/taskinator/queues/resque_spec.rb in taskinator-0.3.0

@@ -53,57 +53,6 @@
       expect_any_instance_of(Taskinator::TaskWorker).to receive(:perform)
       adapter::TaskWorker.perform(uuid)
     end
   end
 
-  describe "JobWorker" do
-    it "enqueues jobs" do
-      worker = adapter::JobWorker
-
-      job = double('job')
-      job_task = double('job_task', :uuid => uuid, :job => job, :queue => nil)
-
-      subject.enqueue_job(job_task)
-      expect(worker).to have_queued(uuid)
-    end
-
-    it "enqueues job to queue of the job class" do
-      worker = adapter::JobWorker
-
-      job = double('job', :queue => :job)
-      job_task = double('job_task', :uuid => uuid, :job => job, :queue => nil)
-
-      subject.enqueue_job(job_task)
-      expect(worker).to have_queued(uuid).in(:job)
-    end
-
-    it "enqueues job to specified queue" do
-      worker = adapter::JobWorker
-
-      job = double('job')
-      job_task = double('job_task', :uuid => uuid, :job => job, :queue => :other)
-
-      subject.enqueue_job(job_task)
-      expect(worker).to have_queued(uuid).in(:other)
-    end
-
-    it "calls job worker" do
-      expect_any_instance_of(Taskinator::JobWorker).to receive(:perform)
-      adapter::JobWorker.perform(uuid)
-    end
-
-    let(:definition) { TestDefinition }
-
-    it "performs invocation on job" do
-      args = [:foo, {:a => 1}]
-      job_class = double('job_class', :methods => [:perform])
-      expect(job_class).to receive(:perform).with(*args)
-
-      process = Taskinator::Process::Sequential.new(definition)
-      job_task = Taskinator::Task.define_job_task(process, job_class, args)
-
-      allow(Taskinator::Task).to receive(:fetch).with(uuid) { job_task }
-
-      adapter::JobWorker.perform(uuid)
-    end
-  end
 end