Reduce batch size (0.1.6)

mixcloud · Nov 13, 2019 · be2b769 · be2b769
1 parent 7b58381
commit be2b769
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/fluent-plugin-indicative.gemspec b/fluent-plugin-indicative.gemspec
@@ -3,7 +3,7 @@ $:.push File.expand_path("../lib", __FILE__)
 
 Gem::Specification.new do |s|
   s.name        = "fluent-plugin-indicative"
-  s.version     = "0.1.5"
+  s.version     = "0.1.6"
   s.authors     = ["Sam Millar"]
   s.email       = ["[email protected]"]
   s.homepage    = "https://github.com/millar/fluent-plugin-indicative"

diff --git a/lib/fluent/plugin/out_indicative.rb b/lib/fluent/plugin/out_indicative.rb
@@ -5,7 +5,7 @@
 
 require 'fluent/plugin/output'
 
-BATCH_SIZE = 100
+BATCH_SIZE = 15
 
 
 def flatten_hash(hash)

diff --git a/test/plugin/test_out_indicative.rb b/test/plugin/test_out_indicative.rb
@@ -69,7 +69,7 @@ def test_emit_buffer
     d = create_driver(BUFFER_CONFIG)
     stub_request(:any, d.instance.api_url)
     d.run(default_tag: 'test') do
-      20.times do
+      5.times do
         d.feed({'event_name' => 'screen_view', 'created_at' => '2015-01-01T10:00:00.000Z', 'session_id' => 'a3bd2', 'user_id' => nil, 'screen' => {'id' => 'index'}})
       end
     end