Skip to content

Commit 032d42b

Browse files
Mats-SXFlorentinD
authored andcommitted
Use a valid concurrency for a public test
1 parent caaada5 commit 032d42b

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)