@@ -40,9 +40,9 @@ public class GlueReconciler implements Reconciler<Glue>, Cleaner<Glue> {
40
40
41
41
private static final Logger log = LoggerFactory .getLogger (GlueReconciler .class );
42
42
public static final String DEPENDENT_NAME_ANNOTATION_KEY =
43
- "io.javaoperatorsdk.operator.resourceflow/ name" ;
43
+ "io.javaoperatorsdk.operator.glue/resource- name" ;
44
44
public static final String PARENT_GLUE_FINALIZER_PREFIX =
45
- "io.javaoperatorsdk.operator.resourceflow. glue/" ;
45
+ "io.javaoperatorsdk.operator.glue/" ;
46
46
public static final String GLUE_RECONCILER_NAME = "glue" ;
47
47
48
48
@@ -97,6 +97,7 @@ public UpdateControl<Glue> reconcile(Glue primary,
97
97
@ Override
98
98
public DeleteControl cleanup (Glue primary , Context <Glue > context ) {
99
99
100
+ registerRelatedResourceInformers (context , primary );
100
101
var actualWorkflow = buildWorkflowAndRegisterInformers (primary , context );
101
102
var result = actualWorkflow .cleanup (primary , context );
102
103
result .throwAggregateExceptionIfErrorsPresent ();
@@ -147,9 +148,8 @@ private UpdateControl<Glue> removeErrorMessageFromGlueStatusIfPresent(Glue prima
147
148
148
149
private void registerRelatedResourceInformers (Context <Glue > context ,
149
150
Glue glue ) {
150
- glue .getSpec ().getRelatedResources ().forEach (r -> {
151
- informerRegister .registerInformerForRelatedResource (context , glue , r );
152
- });
151
+ glue .getSpec ().getRelatedResources ()
152
+ .forEach (r -> informerRegister .registerInformerForRelatedResource (context , glue , r ));
153
153
}
154
154
155
155
// todo test
0 commit comments