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