Skip to content

Commit de1f6a6

Browse files
committed
simplifications
1 parent 608a226 commit de1f6a6

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/enrich/EnrichPolicyResolver.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -436,9 +436,7 @@ public void messageReceived(LookupRequest request, TransportChannel channel, Tas
436436
new ChannelActionListener<>(channel),
437437
threadContext
438438
);
439-
try (
440-
RefCountingListener refs = new RefCountingListener(listener.map(unused -> new LookupResponse(resolvedPolices, failures)))
441-
) {
439+
try (var refs = new RefCountingListener(listener.map(unused -> new LookupResponse(resolvedPolices, failures)))) {
442440
for (String policyName : request.policyNames) {
443441
EnrichPolicy p = availablePolicies.get(policyName);
444442
if (p == null) {
@@ -469,9 +467,7 @@ public void messageReceived(LookupRequest request, TransportChannel channel, Tas
469467
}
470468

471469
protected Map<String, EnrichPolicy> availablePolicies() {
472-
final EnrichMetadata metadata = projectResolver.getProjectMetadata(clusterService.state())
473-
.custom(EnrichMetadata.TYPE, EnrichMetadata.EMPTY);
474-
return metadata.getPolicies();
470+
return projectResolver.getProjectMetadata(clusterService.state()).custom(EnrichMetadata.TYPE, EnrichMetadata.EMPTY).getPolicies();
475471
}
476472

477473
protected void getRemoteConnection(String cluster, ActionListener<Transport.Connection> listener) {

0 commit comments

Comments
 (0)