lib/mongo/collection/view/map_reduce.rb in mongo-2.2.7 vs lib/mongo/collection/view/map_reduce.rb in mongo-2.3.0
- old
+ new
@@ -1,6 +1,6 @@
-# Copyright (C) 2014-2015 MongoDB, Inc.
+# Copyright (C) 2014-2016 MongoDB, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
@@ -209,11 +209,11 @@
def send_initial_query(server)
unless valid_server?(server)
log_warn(REROUTE)
server = cluster.next_primary(false)
end
- result = initial_query_op.execute(server.context)
+ result = initial_query_op.execute(server)
inline? ? result : send_fetch_query(server)
end
def fetch_query_spec
Builder::MapReduce.new(map, reduce, view, options).query_specification
@@ -230,10 +230,10 @@
Operation::Read::Query.new(fetch_query_spec)
end
end
def send_fetch_query(server)
- fetch_query_op(server).execute(server.context)
+ fetch_query_op(server).execute(server)
end
end
end
end
end