@@ -239,11 +239,40 @@ public Result onSuccess(Packet packet, KubernetesApiResponse<T> callResponse) {
239
239
packet .put (DOMAIN_INTROSPECTOR_JOB , job );
240
240
}
241
241
242
+ // TEST
243
+ if (job != null ) {
244
+ System .out .println ("**** RJE: verifying existing job, creation: " + job .getMetadata ().getCreationTimestamp ()
245
+ + ", domain generation: " + getDomain ().getMetadata ().getGeneration () + ", resourceVersion: "
246
+ + getDomain ().getMetadata ().getResourceVersion ());
247
+ } else {
248
+ System .out .println ("**** RJE: verifying existing job, NO JOB "
249
+ + ", domain generation: " + getDomain ().getMetadata ().getGeneration () + ", resourceVersion: "
250
+ + getDomain ().getMetadata ().getResourceVersion ());
251
+ }
252
+
242
253
if (isInProgressJobOutdated (job )) {
254
+
255
+ // TEST
256
+ System .out .println ("**** RJE: job is outdated, creation: " + job .getMetadata ().getCreationTimestamp ()
257
+ + ", domain generation: " + getDomain ().getMetadata ().getGeneration () + ", resourceVersion: "
258
+ + getDomain ().getMetadata ().getResourceVersion ());
259
+
243
260
return doNext (cleanUpAndReintrospect (getNext ()), packet );
244
261
} else if (job != null ) {
262
+
263
+ // TEST
264
+ System .out .println ("**** RJE: processing existing, creation: " + job .getMetadata ().getCreationTimestamp ()
265
+ + ", domain generation: " + getDomain ().getMetadata ().getGeneration () + ", resourceVersion: "
266
+ + getDomain ().getMetadata ().getResourceVersion ());
267
+
245
268
return doNext (processExistingIntrospectorJob (getNext ()), packet );
246
269
} else if (isIntrospectionNeeded (packet )) {
270
+
271
+ // TEST
272
+ System .out .println ("**** RJE: new introspection, domain generation: "
273
+ + getDomain ().getMetadata ().getGeneration () + ", resourceVersion: "
274
+ + getDomain ().getMetadata ().getResourceVersion ());
275
+
247
276
return doNext (createIntrospectionSteps (getNext ()), packet );
248
277
} else {
249
278
return doNext (packet );
0 commit comments