lib/cassandra_object/associations.rb in sessionm-cassandra_object-2.5.8 vs lib/cassandra_object/associations.rb in sessionm-cassandra_object-2.5.9

@@ -36,10 +36,10 @@
         end
       end
       
       def remove(key)
         begin
-          CassandraObject::Base.with_connection(key) do
+          CassandraObject::Base.with_connection(key, :write) do
             ActiveSupport::Notifications.instrument("remove.cassandra_object", column_family: relationships_column_family, key: key) do
               connection.remove(relationships_column_family, key.to_s, consistency: thrift_write_consistency)
             end
           end
         rescue Cassandra::AccessError => e