race condition fix

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/AbstractWorkflowExecutor.java

@@ -174,10 +174,10 @@ protected <R> void submit(
       DependentResourceNode<R, P> dependentResourceNode,
       NodeExecutor<R, P> nodeExecutor,
       String operation) {
+    logger()
+        .debug("Submitting to {}: {} primaryID: {}", operation, dependentResourceNode, primaryID);
     final Future<?> future = executorService.submit(nodeExecutor);
     markAsExecuting(dependentResourceNode, future);
-    logger()
-        .debug("Submitted to {}: {} primaryID: {}", operation, dependentResourceNode, primaryID);
   }
 
   protected <R> void registerOrDeregisterEventSourceBasedOnActivation(

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

@@ -183,8 +183,13 @@ public void handleRecentResourceCreate(ResourceID resourceID, R resource) {
 
   @Override
   public Optional<R> get(ResourceID resourceID) {
-    var res = cache.get(resourceID);
+    // order of these two resource gets matter, since other way around
+    // there can be a race condition that we read the resource from the cache
+    // it is not found. But, right after that we process an event for the informer that
+    // evicts the temporal resource cache, so at the end resource won't be found in temp cache
+    // however it is there already in informer cache at that moment.
     Optional<R> resource = temporaryResourceCache.getResourceFromCache(resourceID);
+    var res = cache.get(resourceID);
     if (comparableResourceVersions
         && resource.isPresent()
         && res.filter(

sample-operators/mysql-schema/src/test/java/io/javaoperatorsdk/operator/sample/MySQLSchemaOperatorE2E.java

@@ -127,7 +127,7 @@ void test() {
         .delete();
 
     await()
-        .atMost(2, MINUTES)
+        .atMost(4, MINUTES)
         .ignoreExceptions()
         .untilAsserted(
             () -> {