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])