File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
operator/src/main/java/oracle/kubernetes/operator Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 3131import oracle .kubernetes .operator .helpers .PodDisruptionBudgetHelper ;
3232import oracle .kubernetes .operator .helpers .PodHelper ;
3333import oracle .kubernetes .operator .helpers .ServiceHelper ;
34+ import oracle .kubernetes .operator .work .FiberGate ;
3435import oracle .kubernetes .operator .work .Packet ;
3536import oracle .kubernetes .weblogic .domain .model .ClusterList ;
3637import oracle .kubernetes .weblogic .domain .model .ClusterResource ;
@@ -220,7 +221,12 @@ private void updateDeletedDomainsInDPI(DomainList list) {
220221 }
221222
222223 private boolean isNotBeingProcessed (String namespace , String domainUid ) {
223- return processor .getMakeRightFiberGateMap ().get (namespace ).getCurrentFibers ().get (domainUid ) == null ;
224+ return Optional .ofNullable (processor )
225+ .map (DomainProcessor ::getMakeRightFiberGateMap )
226+ .map (m -> m .get (namespace ))
227+ .map (FiberGate ::getCurrentFibers )
228+ .map (f -> f .get (domainUid ))
229+ .isEmpty ();
224230 }
225231
226232 private void addDomain (DomainResource domain ) {
You can’t perform that action at this time.
0 commit comments