Skip to content

Commit 5425423

Browse files
author
Mehmetcan Güleşçi
committed
fix(tests): update expectations after main branch changes
1 parent 76ca5b4 commit 5425423

File tree

1 file changed

+11
-14
lines changed

1 file changed

+11
-14
lines changed

api/src/test/java/io/kafbat/ui/service/index/KafkaConnectNgramFilterTest.java

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -14,25 +14,22 @@ class KafkaConnectNgramFilterTest extends AbstractNgramFilterTest<FullConnectorI
1414

1515
@Override
1616
protected NgramFilter<FullConnectorInfoDTO> buildFilter(List<FullConnectorInfoDTO> items,
17-
boolean enabled,
18-
ClustersProperties.NgramProperties ngramProperties) {
17+
boolean enabled,
18+
ClustersProperties.NgramProperties ngramProperties) {
1919
return new KafkaConnectNgramFilter(items, enabled, ngramProperties);
2020
}
2121

2222
@Override
2323
protected List<FullConnectorInfoDTO> items() {
24-
return IntStream.range(0, 100).mapToObj(i ->
25-
new FullConnectorInfoDTO(
26-
"connect-" + i,
27-
"connector-" + i,
28-
"class",
29-
ConnectorTypeDTO.SINK,
30-
List.of(),
31-
new ConnectorStatusDTO(ConnectorStateDTO.RUNNING, "reason"),
32-
1,
33-
0
34-
)
35-
).toList();
24+
return IntStream.range(0, 100).mapToObj(i -> new FullConnectorInfoDTO(
25+
"connect-" + i,
26+
"connector-" + i,
27+
"class",
28+
ConnectorTypeDTO.SINK,
29+
List.of(),
30+
new ConnectorStatusDTO(ConnectorStateDTO.RUNNING, "worker-1", "reason"),
31+
1,
32+
0)).toList();
3633
}
3734

3835
@Override

0 commit comments

Comments
 (0)