diff --git a/test-utils/src/main/java/apoc/periodic/PeriodicTestUtils.java b/test-utils/src/main/java/apoc/periodic/PeriodicTestUtils.java index 423eb16d9..ed6e14153 100644 --- a/test-utils/src/main/java/apoc/periodic/PeriodicTestUtils.java +++ b/test-utils/src/main/java/apoc/periodic/PeriodicTestUtils.java @@ -48,9 +48,9 @@ public static void testTerminatePeriodicQuery(DbmsRule db, String periodicQuery) db.executeTransactionally(periodicQuery, Map.of(), result -> { Map row = Iterators.single(result); - return row.get("wasTerminated"); + return (boolean) row.get("wasTerminated"); }), - (value) -> true, 10L, TimeUnit.SECONDS); + (value) -> value, 15L, TimeUnit.SECONDS); } catch(Exception tfe) { assertEquals(tfe.getMessage(),true, tfe.getMessage().contains("terminated")); }