lib/metacrunch/db/reader.rb in metacrunch-3.1.2 vs lib/metacrunch/db/reader.rb in metacrunch-3.1.3
- old
+ new
@@ -1,9 +1,8 @@
require "metacrunch/db"
module Metacrunch
class Db::Reader
- include Metacrunch::ParallelProcessableReader
def initialize(database_connection_or_url, dataset_proc, options = {})
@rows_per_fetch = options.delete(:rows_per_fetch) || 1000
@db = if database_connection_or_url.is_a?(String)