spec/lib/gush/worker_spec.rb in gush-0.1.1 vs spec/lib/gush/worker_spec.rb in gush-0.1.2

- old
+ new

@@ -21,47 +21,47 @@ context "when job fails" do it "should mark it as failed" do allow(job).to receive(:work).and_raise(StandardError) expect(client).to receive(:worker_report).with(hash_including(status: :failed)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") expect(workflow.find_job("Prepare")).to be_failed end it "reports that job failed" do allow(job).to receive(:work).and_raise(StandardError) expect(client).to receive(:worker_report).with(hash_including(status: :failed)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") end end context "when job completes successfully" do it "should mark it as succedeed" do expect(subject).to receive(:mark_as_finished) expect(client).to receive(:worker_report).with(hash_including(status: :finished)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") end it "reports that job succedeed" do expect(client).to receive(:worker_report).with(hash_including(status: :finished)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") end end it "calls job.work method" do expect(job).to receive(:work) expect(client).to receive(:worker_report).with(hash_including(status: :finished)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") end it "reports when the job is started" do allow(client).to receive(:worker_report) expect(client).to receive(:worker_report).with(hash_including(status: :finished)).ordered - subject.perform(workflow.id, "Prepare", config) + subject.perform(workflow.id, "Prepare") end end end