test/embulk/input/test_mixpanel.rb in embulk-input-mixpanel-0.5.3.alpha.1 vs test/embulk/input/test_mixpanel.rb in embulk-input-mixpanel-0.5.3

- old
+ new

@@ -614,34 +614,34 @@ def setup end def test_incremental_column_with_where page_builder = Object.new - plugin = Mixpanel.new(task.merge(params: task[:params].merge("where" => "abc==def")), nil, nil, page_builder) + plugin = Mixpanel.new(task.merge(params: task[:params].merge("where" => "abc==def"),latest_fetched_time: 1), nil, nil, page_builder) stub(plugin).preview? {false} adjusted = record_epoch - timezone_offset_seconds mock(page_builder).add(["FOO", adjusted, "event"]).times(records.length * 2) mock(page_builder).finish any_instance_of(MixpanelApi::Client) do |klass| stub(klass).export() do |params, block| - assert_equal('(abc==def) and properties["mp_processing_time_ms"] > 0',params["where"]) + assert_equal('(abc==def) and properties["mp_processing_time_ms"] > 1',params["where"]) records.each{|record| block.call(record) } end end task_report = plugin.run assert_equal(1234567919, task_report[:latest_fetched_time]) end def test_incremental_column page_builder = Object.new - plugin = Mixpanel.new(task, nil, nil, page_builder) + plugin = Mixpanel.new(task.merge(latest_fetched_time: 1), nil, nil, page_builder) stub(plugin).preview? {false} adjusted = record_epoch - timezone_offset_seconds mock(page_builder).add(["FOO", adjusted, "event"]).times(records.length * 2) mock(page_builder).finish any_instance_of(MixpanelApi::Client) do |klass| stub(klass).export() do |params, block| - assert_equal('properties["mp_processing_time_ms"] > 0',params["where"]) + assert_equal('properties["mp_processing_time_ms"] > 1',params["where"]) records.each{|record| block.call(record) } end end task_report = plugin.run assert_equal(1234567919, task_report[:latest_fetched_time])