Skip to content

Commit bd00e98

Browse files
committed
fixes on deletion
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 059603d commit bd00e98

File tree

2 files changed

+6
-15
lines changed

2 files changed

+6
-15
lines changed

src/main/java/io/javaoperatorsdk/operator/glue/Utils.java

-7
Original file line numberDiff line numberDiff line change
@@ -135,13 +135,6 @@ public static String getKindFromTemplate(String resourceTemplate) {
135135
return getPropertyValueFromTemplate(resourceTemplate, "kind");
136136
}
137137

138-
public static Set<String> leafResourceNames(Glue glue) {
139-
Set<String> result = new HashSet<>();
140-
glue.getSpec().getChildResources().forEach(r -> result.add(r.getName()));
141-
glue.getSpec().getChildResources().forEach(r -> r.getDependsOn().forEach(result::remove));
142-
return result;
143-
}
144-
145138
private static Optional<String> getOptionalPropertyValueFromTemplate(String resourceTemplate,
146139
String property) {
147140
var finalProp = property + ":";

src/main/java/io/javaoperatorsdk/operator/glue/reconciler/glue/GlueReconciler.java

+6-8
Original file line numberDiff line numberDiff line change
@@ -176,20 +176,18 @@ private void cleanupRemovedResourcesFromWorkflow(Context<Glue> context,
176176
private io.javaoperatorsdk.operator.processing.dependent.workflow.Workflow<Glue> buildWorkflowAndRegisterInformers(
177177
Glue primary, Context<Glue> context) {
178178
var builder = new WorkflowBuilder<Glue>();
179-
Set<String> leafDependentNames = Utils.leafResourceNames(primary);
180179

181180
Map<String, GenericDependentResource> genericDependentResourceMap = new HashMap<>();
182181
primary.getSpec().getChildResources().forEach(spec -> createAndAddDependentToWorkflow(primary,
183-
context, spec, genericDependentResourceMap, builder,
184-
leafDependentNames.contains(spec.getName())));
182+
context, spec, genericDependentResourceMap, builder));
185183

186184
return builder.build();
187185
}
188186

189187
private void createAndAddDependentToWorkflow(Glue primary, Context<Glue> context,
190188
DependentResourceSpec spec,
191189
Map<String, GenericDependentResource> genericDependentResourceMap,
192-
WorkflowBuilder<Glue> builder, boolean leafDependent) {
190+
WorkflowBuilder<Glue> builder) {
193191

194192
// todo test processing ns not as template
195193
// todo test processing ns as template
@@ -203,7 +201,7 @@ private void createAndAddDependentToWorkflow(Glue primary, Context<Glue> context
203201
if (!Boolean.TRUE.equals(spec.getBulk())) {
204202
name = genericTemplateHandler.processTemplate(Utils.getName(spec), primary, false, context);
205203
}
206-
var dr = createDependentResource(name, spec, leafDependent, resourceInSameNamespaceAsPrimary,
204+
var dr = createDependentResource(name, spec, resourceInSameNamespaceAsPrimary,
207205
targetNamespace.orElse(null));
208206
GroupVersionKind gvk = toGVKIfGVKP(dr.getGroupVersionKind());
209207
var es = informerRegister.registerInformer(context, gvk, primary);
@@ -225,10 +223,10 @@ private void createAndAddDependentToWorkflow(Glue primary, Context<Glue> context
225223
}
226224

227225
private GenericDependentResource createDependentResource(String resourceName,
228-
DependentResourceSpec spec,
229-
boolean leafDependent, Boolean resourceInSameNamespaceAsPrimary, String namespace) {
226+
DependentResourceSpec spec, Boolean resourceInSameNamespaceAsPrimary, String namespace) {
230227

231-
if (leafDependent && resourceInSameNamespaceAsPrimary && !spec.isClusterScoped()) {
228+
if (spec.getDependsOn().isEmpty() &&
229+
resourceInSameNamespaceAsPrimary && !spec.isClusterScoped()) {
232230
return spec.getResourceTemplate() != null
233231
? spec.getBulk()
234232
? new GCGenericBulkDependentResource(genericTemplateHandler,

0 commit comments

Comments
 (0)