lib/embulk/input/marketo/base.rb in embulk-input-marketo-0.1.0 vs lib/embulk/input/marketo/base.rb in embulk-input-marketo-0.1.1

@@ -35,10 +35,12 @@
         end
 
         def self.resume(task, columns, count, &control)
           commit_reports = yield(task, columns, count)
 
-          next_config_diff = {}
+          # NOTE: If this plugin supports to run by multi threads, this
+          # implementation is terrible.
+          next_config_diff = commit_reports.first
           return next_config_diff
         end
 
         def self.soap_client(config)
           @soap ||=