Use proper version of Chaotic Job

Gemfile.lock

@@ -51,7 +51,7 @@ GEM
     base64 (0.2.0)
     bigdecimal (3.1.8)
     builder (3.3.0)
-    chaotic_job (0.1.1)
+    chaotic_job (0.2.0)
     combustion (1.3.7)
       activesupport (>= 3.0.0)
       railties (>= 3.0.0)
@@ -162,7 +162,7 @@ PLATFORMS
 
 DEPENDENCIES
   acidic_job!
-  chaotic_job
+  chaotic_job (>= 0.2.0)
   combustion
   minitest
   rake

acidic_job.gemspec

@@ -34,7 +34,7 @@ Gem::Specification.new do |spec|
     spec.add_dependency "railties", rails_version
   end
 
-  spec.add_development_dependency "chaotic_job"
+  spec.add_development_dependency "chaotic_job", ">= 0.2.0"
   spec.add_development_dependency "combustion"
   spec.add_development_dependency "minitest"
   spec.add_development_dependency "rake"

test/acidic_job/basics_test.rb

@@ -21,7 +21,7 @@ def step_3; ChaoticJob.log_to_journal!; end
     end
 
     Job1.perform_later
-    perform_all
+    perform_all_jobs
 
     assert_equal 3, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count
@@ -63,7 +63,7 @@ def step_3; executions > 3 ? ChaoticJob.log_to_journal! : (raise DefaultsError);
     end
 
     Job2.perform_later
-    perform_all
+    perform_all_jobs
 
     assert_equal 3, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count
@@ -111,7 +111,7 @@ def step_3; ChaoticJob.log_to_journal!; end
     end
 
     Job3.perform_later
-    perform_all
+    perform_all_jobs
 
     assert_equal 0, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count
@@ -149,7 +149,7 @@ def step_3; raise DiscardableError; end
     end
 
     ThreeStepDiscardOnThreeJob.perform_later
-    perform_all
+    perform_all_jobs
 
     assert_equal 2, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count
@@ -190,7 +190,7 @@ def step_3; raise StandardError; end
 
     Job4.perform_later
     assert_raises StandardError do
-      perform_all
+      perform_all_jobs
     end
 
     assert_equal 2, ChaoticJob.journal_size
@@ -237,7 +237,7 @@ def step_3; ChaoticJob.log_to_journal!; end
 
     Job5.perform_later
     assert_raises StandardError do
-      perform_all
+      perform_all_jobs
     end
 
     assert_equal 1, ChaoticJob.journal_size
@@ -284,7 +284,7 @@ def step_3; ChaoticJob.log_to_journal!; end
 
     Job6.perform_later
     assert_raises StandardError do
-      perform_all
+      perform_all_jobs
     end
 
     assert_equal 1, ChaoticJob.journal_size
@@ -334,7 +334,7 @@ def step_3; ChaoticJob.log_to_journal!; end
     end
 
     Job7.perform_later
-    perform_all
+    perform_all_jobs
 
     assert_equal 3, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count
@@ -392,7 +392,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       queries << event.payload.fetch(:sql)
     end
     ActiveSupport::Notifications.subscribed(callback, "sql.active_record") do
-      perform_all
+      perform_all_jobs
     end
 
     assert_equal 3, ChaoticJob.journal_size
@@ -460,7 +460,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       queries << event.payload.fetch(:sql)
     end
     ActiveSupport::Notifications.subscribed(callback, "sql.active_record") do
-      perform_all
+      perform_all_jobs
     end
 
     assert_equal 2, ChaoticJob.journal_size
@@ -511,7 +511,7 @@ def step_3; ChaoticJob.log_to_journal!; end
     end
 
     Job10.perform_later(1, 2, 3)
-    perform_all
+    perform_all_jobs
 
     assert_equal 3, ChaoticJob.journal_size
     assert_equal 1, AcidicJob::Execution.count

test/acidic_job/breakages_test.rb

@@ -43,7 +43,7 @@ def step_3; ChaoticJob.log_to_journal!; end
 
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
       assert_raises(BreakingError) do
-        perform_all
+        perform_all_jobs
       end
     end
 
@@ -68,7 +68,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DiscardableError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -94,7 +94,7 @@ def step_3; ChaoticJob.log_to_journal!; end
 
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
       assert_raises(DefaultsError) do
-        perform_all
+        perform_all_jobs
       end
     end
 
@@ -120,7 +120,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -180,7 +180,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -243,7 +243,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -311,7 +311,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -381,7 +381,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised
@@ -447,7 +447,7 @@ def step_3; ChaoticJob.log_to_journal!; end
       raise DefaultsError
     end
     ActiveSupport::Notifications.subscribed(callback, /acidic_job/) do
-      perform_all
+      perform_all_jobs
     end
 
     assert already_raised

test/crucibles/awaiting_test.rb

@@ -68,7 +68,7 @@ def do_something
 
     test "workflow runs successfully" do
       Job.perform_later
-      perform_all
+      perform_all_jobs
 
       assert_equal 3, ChaoticJob.journal_size
       assert_equal 1, AcidicJob::Execution.count

test/crucibles/delaying_test.rb

@@ -34,7 +34,7 @@ def do_something
 
     test "workflow runs successfully" do
       Job.perform_later
-      perform_all_within(1.minute)
+      perform_all_jobs_within(1.minute)
 
       # Performed the first job, then retried it
       assert_equal 1, performed_jobs.size
@@ -63,7 +63,7 @@ def do_something
       assert_equal false, AcidicJob::Value.find_by(key: "halt").value
 
       # Now, perform the future scheduled job and check the final state of the execution
-      perform_all_after(14.days)
+      perform_all_jobs_after(14.days)
 
       assert_equal 1, ChaoticJob.journal_size
       assert_equal 1, AcidicJob::Execution.count
@@ -123,7 +123,7 @@ def do_something
 
     test "scenario with error before halt_step!" do
       run_scenario(Job.new, glitch: ["before", "#{__FILE__}:27"]) do
-        perform_all_within(1.minute)
+        perform_all_jobs_within(1.minute)
       end
 
       # Performed the first job, then retried it
@@ -154,7 +154,7 @@ def do_something
       assert_equal false, AcidicJob::Value.find_by(key: "halt").value
 
       # Now, perform the future scheduled job and check the final state of the execution
-      perform_all_after(14.days)
+      perform_all_jobs_after(14.days)
 
       assert_equal 1, ChaoticJob.journal_size
       assert_equal 1, AcidicJob::Execution.count

test/crucibles/iteration_test.rb

@@ -29,7 +29,7 @@ def step_1
 
     test "workflow runs successfully" do
       Job.perform_later
-      perform_all
+      perform_all_jobs
 
       assert_equal 3, ChaoticJob.journal_size
       assert_equal 1, AcidicJob::Execution.count

test/crucibles/waiting_test.rb

@@ -29,7 +29,7 @@ def do_something
 
     test "workflow runs successfully" do
       Job.perform_later
-      perform_all
+      perform_all_jobs
 
       assert_equal 1, ChaoticJob.journal_size
       assert_equal 1, AcidicJob::Execution.count