Skip to content

Commit ef3b067

Browse files
authored
Use a valid concurrency for a public test
1 parent 7d5f62f commit ef3b067

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

proc/catalog/src/test/java/org/neo4j/gds/catalog/GraphStreamRelationshipsProcTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ void shouldStreamInParallel() {
133133
runQuery("CALL gds.beta.graph.generate('generatedGraph', 10000, 5)");
134134

135135
var actualRelationships = new ArrayList<TopologyResult>();
136-
runQueryWithRowConsumer("CALL gds.beta.graph.relationships.stream('generatedGraph', ['*'], { concurrency: 10 })", row -> actualRelationships.add(
136+
runQueryWithRowConsumer("CALL gds.beta.graph.relationships.stream('generatedGraph', ['*'], { concurrency: 4 })", row -> actualRelationships.add(
137137
relationship(
138138
row.getNumber("sourceNodeId").longValue(),
139139
row.getNumber("targetNodeId").longValue(),

0 commit comments

Comments
 (0)