From 14a18bba3a2098c05c4ce3c917ddd447b1d742c5 Mon Sep 17 00:00:00 2001
From: Ali Ince <ali-ince@users.noreply.github.com>
Date: Tue, 30 Jul 2024 10:52:24 +0100
Subject: [PATCH] Consume delete statement results (#644)

---
 .../kotlin/streams/kafka/connect/source/Neo4jSourceTaskTest.kt  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka-connect-neo4j/src/test/kotlin/streams/kafka/connect/source/Neo4jSourceTaskTest.kt b/kafka-connect-neo4j/src/test/kotlin/streams/kafka/connect/source/Neo4jSourceTaskTest.kt
index 19e17316..049b85e5 100644
--- a/kafka-connect-neo4j/src/test/kotlin/streams/kafka/connect/source/Neo4jSourceTaskTest.kt
+++ b/kafka-connect-neo4j/src/test/kotlin/streams/kafka/connect/source/Neo4jSourceTaskTest.kt
@@ -55,7 +55,7 @@ class Neo4jSourceTaskTest {
 
     @After
     fun after() {
-        session.run("MATCH (n) DETACH DELETE n")
+        session.run("MATCH (n) DETACH DELETE n").consume()
         task.stop()
     }