lib/neo4j/migrations/base.rb in neo4j-9.6.2 vs lib/neo4j/migrations/base.rb in neo4j-10.0.0.pre.alpha.1
- old
+ new
@@ -65,10 +65,10 @@
def migration_transaction(&block)
ActiveBase.run_transaction(transactions?, &block)
end
def log_queries
- subscriber = Neo4j::Core::CypherSession::Adaptors::Base.subscribe_to_query(&method(:output))
+ subscriber = Neo4j::Transaction.subscribe_to_query(&method(:output))
yield
ensure
ActiveSupport::Notifications.unsubscribe(subscriber) if subscriber
end
end