The apoc.cypher.runSchemaFile() never finishes execution

[vga91]

The apoc.cypher.runSchemaFile() never finishes execution

[vga91]

Isolated test case

Note that the issue occurs also with a test container and with a real Neo4j instance

import apoc.util.TestUtil;
import org.junit.*;
import org.neo4j.graphdb.*;
import org.neo4j.procedure.*;
import org.neo4j.test.rule.*;

import java.util.Map;
import java.util.stream.Stream;

public class PendingTest {

    public static class MockProcedure {
        public record MockResult(String value) {}

        @Context public GraphDatabaseService db;

        @Procedure(name = "my.proc", mode = Mode.SCHEMA)
        public Stream<MockResult> myProcedure() {
            // should throw an EquivalentSchemaRuleAlreadyExistsException,
            // instead it remains in pending
            db.executeTransactionally("CREATE CONSTRAINT FOR (n:Person) REQUIRE n.name IS UNIQUE", Map.of(), Result::resultAsString);
            return Stream.of(new MockResult("test"));
        }
    }

    @ClassRule
    public static DbmsRule db = new ImpermanentDbmsRule();

    @BeforeClass
    public static void setUp() {
        TestUtil.registerProcedure(db, MockProcedure.class);
    }

    @Test
    public void test() {
        db.executeTransactionally("CREATE CONSTRAINT FOR (n:Person) REQUIRE n.name IS UNIQUE");

        try {
            db.executeTransactionally("CALL my.proc()", Map.of(), Result::resultAsString);
        } catch (Exception e) {
            Assert.assertTrue(e.getMessage().contains("equivalent constraint already exists"));
        }
    }
}

NOTE: By changing the MockProcedure class to the following, solves the problem:

    public static class MockProcedure {
        public record MockResult(String value) {}

        @Context public Transaction tx;

        @Procedure(name = "my.proc", mode = Mode.SCHEMA)
        public Stream<MockResult> myProcedure() {
            tx.execute("CREATE CONSTRAINT FOR (n:Person) REQUIRE n.name IS UNIQUE", Map.of()).resultAsString();
            return Stream.of(new MockResult("test"));
        }
    }

[vga91]

Since it might be a Neo4j issue, I also created a similar issue in the main repository

\cc @jexp