lib/mongo/collection/view/aggregation.rb in mongo-2.14.1 vs lib/mongo/collection/view/aggregation.rb in mongo-2.15.0.alpha

@@ -132,10 +132,10 @@
           unless valid_server?(server)
             log_warn("Rerouting the Aggregation operation to the primary server - #{server.summary} is not suitable")
             server = cluster.next_primary(nil, session)
           end
           validate_collation!(server)
-          initial_query_op(session).execute(server, client: client)
+          initial_query_op(session).execute(server, context: Operation::Context.new(client: client, session: session))
         end
 
         def validate_collation!(server)
           if options[:collation] && !server.with_connection { |connection| connection.features }.collation_enabled?
             raise Error::UnsupportedCollation.new