Table status cache race condition fixed.

piotrczarnas · piotrczarnas · commit 8da178b84099 · 2024-06-17T16:38:01.000+02:00
diff --git a/dqops/src/main/java/com/dqops/data/checkresults/statuscache/TableStatusCacheImpl.java b/dqops/src/main/java/com/dqops/data/checkresults/statuscache/TableStatusCacheImpl.java
@@ -87,6 +87,8 @@ public TableStatusCacheImpl(DqoCacheConfigurationProperties dqoCacheConfiguratio
         this.userDomainIdentityFactory = userDomainIdentityFactory;
         this.emitFailureHandlerPublisher = Sinks.EmitFailureHandler.busyLooping(Duration.ofSeconds(
                 this.dqoQueueConfigurationProperties.getPublishBusyLoopingDurationSeconds()));
+        this.queueEmptyFuture = new CompletableFuture<>();
+        this.queueEmptyFuture.complete(0);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,8 @@ public TableStatusCacheImpl(DqoCacheConfigurationProperties dqoCacheConfiguratio`
`87`	`87`	`this.userDomainIdentityFactory = userDomainIdentityFactory;`
`88`	`88`	`this.emitFailureHandlerPublisher = Sinks.EmitFailureHandler.busyLooping(Duration.ofSeconds(`
`89`	`89`	`this.dqoQueueConfigurationProperties.getPublishBusyLoopingDurationSeconds()));`
	`90`	`+ this.queueEmptyFuture = new CompletableFuture<>();`
	`91`	`+ this.queueEmptyFuture.complete(0);`
`90`	`92`	`}`
`91`	`93`
`92`	`94`	`/**`