Kiba now defaults to "StreamingRunner" for processing jobs

lib/kiba.rb

@@ -13,7 +13,7 @@
 module Kiba
   def self.run(job)
     # NOTE: use Hash#dig when Ruby 2.2 reaches EOL
-    runner = job.config.fetch(:kiba, {}).fetch(:runner, Kiba::Runner)
+    runner = job.config.fetch(:kiba, {}).fetch(:runner, Kiba::StreamingRunner)
     runner.run(job)
   end
 end

test/shared_runner_tests.rb

@@ -3,10 +3,6 @@
 require_relative 'support/test_destination_returning_nil'
 
 module SharedRunnerTests
-  def kiba_run(job)
-    Kiba.run(job)
-  end
-
   def rows
     @rows ||= [
       { identifier: 'first-row' },

test/test_run.rb

@@ -0,0 +1,12 @@
+require_relative 'helper'
+require 'minitest/mock'
+
+class TestRun < Kiba::Test
+  def test_ensure_kiba_defaults_to_streaming_runner
+    cb = -> (job) { "Streaming runner called" }
+    Kiba::StreamingRunner.stub(:run, cb) do
+      job = Kiba::Control.new
+      assert_equal "Streaming runner called", Kiba.run(job)
+    end
+  end
+end

test/test_runner.rb

@@ -2,5 +2,10 @@
 require_relative 'shared_runner_tests'
 
 class TestRunner < Kiba::Test
+  def kiba_run(job)
+    job.config[:kiba] = {runner: Kiba::Runner}
+    Kiba.run(job)
+  end
+
   include SharedRunnerTests
 end

test/test_streaming_runner.rb

@@ -8,17 +8,18 @@
 require_relative 'shared_runner_tests'
 
 class TestStreamingRunner < Kiba::Test
+  def kiba_run(job)
+    job.config[:kiba] = {runner: Kiba::StreamingRunner}
+    Kiba.run(job)
+  end
+
   include SharedRunnerTests
 
   def test_yielding_class_transform
     input_row = {tags: ["one", "two", "three"]}
     destination_array = []
 
     job = Kiba.parse do
-      extend Kiba::DSLExtensions::Config
-
-      config :kiba, runner: Kiba::StreamingRunner
-
       # provide a single row as the input
       source TestEnumerableSource, [input_row]
 
@@ -51,9 +52,6 @@ def test_yielding_class_transform
   def test_transform_yielding_from_close
     destination_array = []
     job = Kiba.parse do
-      extend Kiba::DSLExtensions::Config
-      config :kiba, runner: Kiba::StreamingRunner
-
       transform CloseYieldingTransform, yield_on_close: [1, 2]
       destination TestArrayDestination, destination_array
     end
@@ -63,9 +61,6 @@ def test_transform_yielding_from_close
 
   def test_transform_with_no_close_must_not_raise
     job = Kiba.parse do
-      extend Kiba::DSLExtensions::Config
-      config :kiba, runner: Kiba::StreamingRunner
-
       transform NonClosingTransform
     end
     Kiba.run(job)