lib/cassandra_object/schema/migrator.rb in sessionm-cassandra_object-2.7.2 vs lib/cassandra_object/schema/migrator.rb in sessionm-cassandra_object-2.7.3
- old
+ new
@@ -48,10 +48,10 @@
Tasks::ColumnFamily.new(cas.keyspace)
end
def self.get_all_versions
cas = CassandraObject::Base.connection
- cas.get(schema_migrations_column_family, 'all').map {|(name, _value)| name.to_i}.sort
+ cas.multi_get(schema_migrations_column_family, ['all'])['all'].map {|(name, _value)| name.to_i}.sort
end
def self.current_version
sm_cf = schema_migrations_column_family
if column_family_tasks.exists?(sm_cf)