Skip to content

Commit 17f91b9

Browse files
authored
Remove unnecessary executeBlocking call (#11269)
Signed-off-by: Katherine Stanley <[email protected]>
1 parent 7688e97 commit 17f91b9

File tree

1 file changed

+1
-4
lines changed
  • cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly

1 file changed

+1
-4
lines changed

cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/CaReconciler.java

+1-4
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,7 @@ Future<Void> reconcileCas(Clock clock) {
224224
String clientsCaKeyName = KafkaResources.clientsCaKeySecretName(reconciliation.name());
225225

226226
return secretOperator.listAsync(reconciliation.namespace(), Labels.EMPTY.withStrimziKind(reconciliation.kind()).withStrimziCluster(reconciliation.name()))
227-
.compose(clusterSecrets -> vertx.executeBlocking(() -> {
227+
.compose(clusterSecrets -> {
228228
Secret clusterCaCertSecret = null;
229229
Secret clusterCaKeySecret = null;
230230
Secret clientsCaCertSecret = null;
@@ -267,9 +267,6 @@ Future<Void> reconcileCas(Clock clock) {
267267
clientsCaConfig != null && !clientsCaConfig.isGenerateSecretOwnerReference() ? null : ownerRef,
268268
Util.isMaintenanceTimeWindowsSatisfied(reconciliation, maintenanceWindows, clock.instant()));
269269

270-
return null;
271-
}))
272-
.compose(i -> {
273270
Promise<Void> caUpdatePromise = Promise.promise();
274271

275272
List<Future<ReconcileResult<Secret>>> secretReconciliations = new ArrayList<>(2);

0 commit comments

Comments
 (0)