Return keyspaces for appropriate server

brainopia · Jun 24, 2013 · a6c3659 · a6c3659
1 parent 7881ec3
commit a6c3659
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/cassandra/mapper/extend/schema.rb b/lib/cassandra/mapper/extend/schema.rb
@@ -17,7 +17,7 @@ def self.env=(env)
 
   def self.keyspaces
     schema[:keyspaces].map do |name|
-      Cassandra.new "#{name}_#{env}"
+      Cassandra.new "#{name}_#{env}", server
     end
   end