57
57
import static oracle .kubernetes .operator .DomainStatusUpdater .createProgressingStartedEventStep ;
58
58
import static oracle .kubernetes .operator .LabelConstants .INTROSPECTION_DOMAIN_SPEC_GENERATION ;
59
59
import static oracle .kubernetes .operator .LabelConstants .INTROSPECTION_STATE_LABEL ;
60
+ import static oracle .kubernetes .operator .ProcessingConstants .DOMAIN_INTROSPECT_REQUESTED ;
60
61
import static oracle .kubernetes .operator .logging .MessageKeys .INTROSPECTOR_JOB_FAILED ;
61
62
import static oracle .kubernetes .operator .logging .MessageKeys .INTROSPECTOR_JOB_FAILED_DETAIL ;
62
63
@@ -98,7 +99,7 @@ private static boolean runIntrospector(Packet packet, DomainPresenceInfo info) {
98
99
LOGGER .fine ("isModelInImageUpdate: " + isModelInImageUpdate (packet , info ));
99
100
return topology == null
100
101
|| isBringingUpNewDomain (packet , info )
101
- || isIntrospectionRequestedAndRemove (packet )
102
+ || checkIfIntrospectionRequestedAndReset (packet )
102
103
|| isModelInImageUpdate (packet , info )
103
104
|| isIntrospectVersionChanged (packet , info );
104
105
}
@@ -107,8 +108,8 @@ private static boolean isBringingUpNewDomain(Packet packet, DomainPresenceInfo i
107
108
return runningServersCount (info ) == 0 && creatingServers (info ) && isGenerationChanged (packet , info );
108
109
}
109
110
110
- private static boolean isIntrospectionRequestedAndRemove (Packet packet ) {
111
- return packet .remove (ProcessingConstants . DOMAIN_INTROSPECT_REQUESTED ) != null ;
111
+ private static boolean checkIfIntrospectionRequestedAndReset (Packet packet ) {
112
+ return packet .remove (DOMAIN_INTROSPECT_REQUESTED ) != null ;
112
113
}
113
114
114
115
private static boolean isIntrospectVersionChanged (Packet packet , DomainPresenceInfo info ) {
@@ -506,6 +507,7 @@ private Step readDomainIntrospectorPodLog(String jobPodName, String namespace, S
506
507
}
507
508
508
509
private static class ReadDomainIntrospectorPodLogResponseStep extends ResponseStep <String > {
510
+ public static final String INTROSPECTION_FAILED = "INTROSPECTION_FAILED" ;
509
511
private StringBuilder logMessage = new StringBuilder ();
510
512
private final List <String > severeStatuses = new ArrayList <>();
511
513
@@ -552,6 +554,7 @@ public NextAction onSuccess(Packet packet, CallResponse<String> callResponse) {
552
554
getJobCreationTime (domainIntrospectorJob ).plus (retryIntervalSeconds , SECONDS ))) {
553
555
//Introspector job is incomplete and current time is greater than the lazy deletion time for the job,
554
556
//update the domain status and execute the next step
557
+ packet .put (DOMAIN_INTROSPECT_REQUESTED , INTROSPECTION_FAILED );
555
558
nextStep = getNext ();
556
559
}
557
560
0 commit comments