diff --git a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java b/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java
index bea21f9170..b0dea3ac66 100644
--- a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java
+++ b/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java
@@ -342,7 +342,7 @@ private Source<Entry<Pair<Policy, Set<PolicyTag>>>, NotUsed> readCachedEnforcer(
                                             .ifPresent(causingPolicyTag -> {
                                                 final boolean invalidated = policyEnforcerCache.invalidateConditionally(
                                                         new PolicyIdResolvingImports(causingPolicyTag.getEntityId(), false),
-                                                        entry -> entry.exists() &&
+                                                        entry -> !entry.exists() ||
                                                                 entry.getRevision() < causingPolicyTag.getRevision()
                                                 );
                                                 log.debug("Causing policy tag was invalidated conditionally: <{}>",