Error with importing table to DQOps

Description:
Error with importing table to DQOps, happened with Trino and MySQL.
Deployment:
Docker
docker run -v [enter the path to your local userhome folder]:/dqo/userhome -d -it -m=4g -p 8888:8888 dqops/dqo run
Not having -it leads into instant collapsed docker container even though first deployment worked fine.
What happened:
First, i deployed DQOps without the -it flag. It worked like a charm, everything is fine until i restarted my device, and then restarted DQOps container, it ran for about 7 to 10 seconds and collapsed. If -it, it worked again.
But here comes the second issue i faced. When i created data sources (Trino and MySQL in this case), it connected as expected, the schemas and tables were showing, but when i import those table, it stuck loading and a new notification poped up:

java.lang.NullPointerException: Cannot invoke "reactor.core.publisher.Sinks$Many.emitNext(Object, reactor.core.publisher.Sinks$EmitFailureHandler)" because "this.loadTableStatusRequestSink" is null at com.dqops.data.checkresults.statuscache.TableStatusCacheImpl.loadEntryCore(TableStatusCacheImpl.java:99) Suppressed: The stacktrace has been enhanced by Reactor, refer to additional information below: Error has been observed at the following site(s): *__checkpoint ⇢ com.dqops.rest.server.authentication.AuthenticateWithDqoCloudWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ com.dqops.rest.server.ServeIndexHtmlWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.AuthorizationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.ExceptionTranslationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authentication.logout.LogoutWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.savedrequest.ServerRequestCacheWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.ReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ com.dqops.rest.server.authentication.AuthenticateWithDqoCloudWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.header.HttpHeaderWriterWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.config.web.server.ServerHttpSecurity$ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain] *__checkpoint ⇢ HTTP GET "/api/connections/MySQL/schemas/test_dqops/tables" [ExceptionHandlingWebHandler] Original Stack Trace: at com.dqops.data.checkresults.statuscache.TableStatusCacheImpl.loadEntryCore(TableStatusCacheImpl.java:99) at com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2688) at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916) at com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2686) at com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2669) at com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) at com.github.benmanes.caffeine.cache.LocalManualCache.get(LocalManualCache.java:62) at com.dqops.data.checkresults.statuscache.TableStatusCacheImpl.getCurrentTableStatus(TableStatusCacheImpl.java:125) at com.dqops.rest.controllers.TablesController.lambda$getTables$2(TablesController.java:239) at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) at com.dqops.rest.controllers.TablesController.getTables(TablesController.java:236) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at org.springframework.web.reactive.result.method.InvocableHandlerMethod.lambda$invoke$0(InvocableHandlerMethod.java:145) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:132) at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:293) at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:474) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:180) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:145) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.Operators.complete(Operators.java:137) at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:145) at reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:57) at reactor.core.publisher.MonoZip$ZipCoordinator.request(MonoZip.java:216) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onSubscribe(MonoIgnoreThen.java:134) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:125) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:240) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:203) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:189) at reactor.core.publisher.Operators.complete(Operators.java:137) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:121) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:263) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:258) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:863) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:180) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.request(MonoPeekTerminal.java:139) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:338) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:70) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnorePublisher.subscribe(MonoIgnorePublisher.java:57) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:155) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:258) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:863) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.MonoAny$AnySubscriber.onNext(MonoAny.java:98) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:453) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:724) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:256) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:118) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onNext(FluxFilterFuseable.java:337) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onSubscribe(MonoFlatMap.java:291) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:96) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.request(FluxMap.java:295) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.request(FluxFilterFuseable.java:411) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.request(FluxMapFuseable.java:360) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.request(FluxFilterFuseable.java:191) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onSubscribe(FluxFlattenIterable.java:241) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onSubscribe(FluxFilterFuseable.java:87) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onSubscribe(FluxMapFuseable.java:265) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onSubscribe(FluxFilterFuseable.java:305) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) at reactor.core.publisher.FluxFilter$FilterSubscriber.onSubscribe(FluxFilter.java:85) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onSubscribe(FluxMap.java:194) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:489) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:422) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:210) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.request(FluxPeekFuseable.java:144) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:371) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:178) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:206) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerComplete(FluxConcatMapNoPrefetch.java:274) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onComplete(FluxConcatMap.java:887) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:189) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2547) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:102) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:847) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:609) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:589) at reactor.core.publisher.FluxFlatMap$FlatMapMain.request(FluxFlatMap.java:347) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.request(FluxPeekFuseable.java:783) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:338) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.request(FluxDefaultIfEmpty.java:98) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.FluxFilter$FilterSubscriber.onSubscribe(FluxFilter.java:85) at reactor.core.publisher.Operators$BaseFluxToMonoOperator.onSubscribe(Operators.java:2025) at reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:70) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:263) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2547) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:102) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:847) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:609) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:589) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:466) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:357) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.request(FluxPeekFuseable.java:144) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:371) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:178) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2071) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onComplete(FluxDefaultIfEmpty.java:134) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:275) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1840) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.signalCached(MonoCacheTime.java:337) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.onNext(MonoCacheTime.java:354) at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:200) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoPublishOn$PublishOnSubscriber.run(MonoPublishOn.java:181) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840)

How to reproduce:
As described above, it all started after a docker restart and i deleted the folder used as dqhome in my device for a fresh start.
What to expect:
Everything works just fine again, including the Incident is not being created when there's checking issue (i wonder if it depends on the severity of the issue or not)
Any help would be much appreciated!
Thanks in advance.

The first problem that the container failed to start was caused by starting the container both with -d (background, daemon mode) and -it (interactive mode).
When the DQOps container was started once with the -d parameter, docker started it in the background, and you already have a running DQOps instance. Another instance cannot start, because the port 8888 is in use by the DQOps instance that is already running. You have to play a little with docker commands to stop background containers. That is not a bug in DQOps.
The second issue with the error is probably also caused by the same problem that two instances of DQOps are running and one instance was stopping.
You can also check out the most recent version of DQOps (1.4.0), which was released yesterday. The bug in the file TableStatusCacheImpl.java (line 99) is fixed there, and the code is protected from issues caused by too early access to the cache before it was fully initialized.
If you are still stuck on this issue, please use the Calendly link on our website (https://dqops.com/contact-us/) and find a timeslot on the calendar. We can review the issue, because I am also curious what was special on your environment that you faced these problems.

Pulled the latest image and deploy once again, the error above is gone, but replaced with another one

java.lang.NullPointerException: Cannot invoke "java.util.concurrent.CompletableFuture.thenApply(java.util.function.Function)" because "this.queueEmptyFuture" is null at com.dqops.data.checkresults.statuscache.TableStatusCacheImpl.getQueueEmptyFuture(TableStatusCacheImpl.java:179) Suppressed: The stacktrace has been enhanced by Reactor, refer to additional information below: Error has been observed at the following site(s): *__checkpoint ⇢ com.dqops.rest.server.authentication.AuthenticateWithDqoCloudWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ com.dqops.rest.server.ServeIndexHtmlWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.AuthorizationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.ExceptionTranslationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authentication.logout.LogoutWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.savedrequest.ServerRequestCacheWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.ReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ com.dqops.rest.server.authentication.AuthenticateWithDqoCloudWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.header.HttpHeaderWriterWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.config.web.server.ServerHttpSecurity$ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain] *__checkpoint ⇢ HTTP GET "/api/connections/trino-poc-datahub/schemas/datahub_schema/tables" [ExceptionHandlingWebHandler] Original Stack Trace: at com.dqops.data.checkresults.statuscache.TableStatusCacheImpl.getQueueEmptyFuture(TableStatusCacheImpl.java:179) at com.dqops.rest.controllers.TablesController.getTables(TablesController.java:246) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at org.springframework.web.reactive.result.method.InvocableHandlerMethod.lambda$invoke$0(InvocableHandlerMethod.java:145) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:132) at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:293) at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:474) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:180) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:145) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.Operators.complete(Operators.java:137) at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:145) at reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:57) at reactor.core.publisher.MonoZip$ZipCoordinator.request(MonoZip.java:216) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onSubscribe(MonoIgnoreThen.java:134) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:125) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:240) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:203) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:189) at reactor.core.publisher.Operators.complete(Operators.java:137) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:121) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:263) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:258) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:863) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:180) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.request(MonoPeekTerminal.java:139) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:338) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:70) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnorePublisher.subscribe(MonoIgnorePublisher.java:57) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:155) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:258) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:863) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.MonoAny$AnySubscriber.onNext(MonoAny.java:98) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:453) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:724) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:256) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:118) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onNext(FluxFilterFuseable.java:337) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onSubscribe(MonoFlatMap.java:291) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:96) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2545) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.request(FluxMap.java:295) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.request(FluxFilterFuseable.java:411) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.request(FluxMapFuseable.java:360) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.request(FluxFilterFuseable.java:191) at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onSubscribe(FluxFlattenIterable.java:241) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onSubscribe(FluxFilterFuseable.java:87) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onSubscribe(FluxMapFuseable.java:265) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onSubscribe(FluxFilterFuseable.java:305) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) at reactor.core.publisher.FluxFilter$FilterSubscriber.onSubscribe(FluxFilter.java:85) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onSubscribe(FluxMap.java:194) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:489) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:422) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:210) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.request(FluxPeekFuseable.java:144) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:371) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:178) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:206) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerComplete(FluxConcatMapNoPrefetch.java:274) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onComplete(FluxConcatMap.java:887) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:189) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2547) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:102) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:847) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:609) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:589) at reactor.core.publisher.FluxFlatMap$FlatMapMain.request(FluxFlatMap.java:347) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.request(FluxPeekFuseable.java:783) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:338) at reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:108) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.request(FluxDefaultIfEmpty.java:98) at reactor.core.publisher.FluxFilter$FilterSubscriber.request(FluxFilter.java:186) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.FluxFilter$FilterSubscriber.onSubscribe(FluxFilter.java:85) at reactor.core.publisher.Operators$BaseFluxToMonoOperator.onSubscribe(Operators.java:2025) at reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:70) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:263) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2547) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2215) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4485) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:102) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:847) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:609) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:589) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:466) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:357) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.request(FluxPeekFuseable.java:144) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:371) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:178) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2071) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onComplete(FluxDefaultIfEmpty.java:134) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:275) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1840) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.signalCached(MonoCacheTime.java:337) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.onNext(MonoCacheTime.java:354) at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:200) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74) at reactor.core.publisher.MonoPublishOn$PublishOnSubscriber.run(MonoPublishOn.java:181) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840)

Im deploying with this docker-compose
version: '1.0' services:    dqops:     container_name: dqops     image: dqops/dqo:latest     stdin_open: true      tty: true       deploy:       resources:         limits:           memory: 4g      volumes:       - .:/dqo/userhome     ports:       - "8888:8888"
Any idea? thanks in advance

It is a race condition during the initialization, probably the rest api is called when the backend is starting and has not yet initialized all caches. It is fixed in the develop branch.
We publish a development image to docker hub once a day, the image is named: dqops/dqo:develop


Throw exception on item and attribute annotations on tuple struct

Quick question on this: should we be allowing #[pyo3(item)] here? Is there any reasonable interpretation beside the elements always being item 0, item 1, item 2 etc?
I wonder if we want to consider throwing an error if #[pyo3(item)] or #[pyo3(attribute)] are used on tuple struct elements.
Originally posted by @davidhewitt in https://github.com/PyO3/pyo3/pull/2181#discussion_r814210259

Thanks, looks like that is indeed the case. The error message I introduced is perhaps not the greatest (could say something about item or attribute rather than getter?), however it's good enough to say this is done.


Updated README example to align with text

Issue #15 -- The first note below the Person example code refers to declaring the
Decodable conformance in an extension. Updated the example code to
reflect this.

Awesome! Thanks for putting this together @richellis...much appreciated! 🍻


REI support for machines

(disclaimer I only did limited testing with the mod)
Since it seems like not all items can be calcinated/dissolved/synthesized it would be nice to have support for those machines (and any that I missed) in REI so that you can easily look up things like:

What can be calcinated/dissolved/synthesized
What do you need to synthesize something (that's easily checked on the table itself but it's good to see everything in one place)
What are good sources of materia/essentia
What can you do with spare essentia

Definitely something I'd like to have, although I haven't really looked into the API yet.

Art of Alchemy is now being maintained by a different team in a new repository. Please use https://github.com/Cumulus-Mods/Art-of-Alchemy/issues/8 for further discussion on this issue. Thank you.


Some minor updates

This update is a revision to an earlier one that somehow broke! My bad I assume!
Changes:

noted that the article focuses on both the ARM and MSOnline Backup cmdlets
noted you may also need to update any older script to use the latest cmdlets.
Updated region names in some example to "WestUS" from 'West US'
Embolding a cmdlet name for better visibility and consistency.
Added details on how you can use PowerShell to download the MARS agent
Updated an example to be correct
Added details about the environment variable and that it's not updated.
8, Corrected example on setting pass codes to be correct - earlier version did nto reallhy work.
Updated outout of example to be up to date
Removed a bit of passive voice from the document

Hi @markgalioto - Please assist with the review of these proposed changes. Thanks

@doctordns thank you for catching and fixing these issues. This improves the readability of the article.

#sign-off


[CIVP-10635] Adding retries during the call to /endpoints in get_swagger_spec

This retries the call to /endpoints while instantiating the client for certain errors.   Another possible route might be to pass the _session object from APIClient, but this would prevent us from being able to memoize generate_classes.

LGTM


Logged in User checkout

change onclikc method of Submit Payment button to execute what comes next.
make route to convert a given userId's cart purchase to a purchased purchase.
make a createUserOrder thunk in cart reducer.
import thunk from #3 into Checkout.js and execute in the 'resetCart' helper method.


make vault loader's TTL ratio configurable

Make the TTL Ratio on the vault loader's TTL configurable.
Previously it was hard coded at 75% of the key's TTL.

Codecov Report

Merging #44 into master will increase coverage by 0.8%.
The diff coverage is 100%.

@@            Coverage Diff            @@
##           master      #44     +/-   ##
=========================================
+ Coverage   91.66%   92.47%   +0.8%
=========================================
  Files          29       29
  Lines        1331     1514    +183
=========================================
+ Hits         1220     1400    +180
- Misses         71       72      +1
- Partials       40       42      +2

Impacted Files
Coverage Δ

loader/klvault/vaultloader.go
80.76% <100%> (+0.5%)
:arrow_up:

util.go
100% <0%> (ø)
:arrow_up:

getter.go
100% <0%> (ø)
:arrow_up:

config.go
92.1% <0%> (+1.62%)
:arrow_up:

loader.go
89.04% <0%> (+5.36%)
:arrow_up:

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update d4eea79...966d49e. Read the comment docs.


The output of sort-object is different on ps5 and ps7

Prerequisites

[X] Write a descriptive title.
[X] Make sure you are able to repro it on the latest released version
[X] Search the existing issues.
[X] Refer to the FAQ.
[X] Refer to Differences between Windows PowerShell 5.1 and PowerShell.

Steps to reproduce
When I execute this code I get different answers, which makes me confused. It looks like the ps5 output is out of order.
@(1..9)|sort-object {1}
powershell 5's output:
7
6
9
8
5
2
1
4
3
powershell7's output:
1
2
3
4
5
6
7
8
9
Expected behavior
1
2
3
4
5
6
7
8
9

Actual behavior
7
6
9
8
5
2
1
4
3

Error details
No response
Environment data
Name                           Value
----                           -----
PSVersion                      5.1.19041.3570
PSEdition                      Desktop
PSCompatibleVersions           {1.0, 2.0, 3.0, 4.0...}
BuildVersion                   10.0.19041.3570
CLRVersion                     4.0.30319.42000
WSManStackVersion              3.0
PSRemotingProtocolVersion      2.3
SerializationVersion           <IP_ADDRESS>

Name                           Value
----                           -----
PSVersion                      7.3.0-preview.3
PSEdition                      Core
GitCommitId                    7.3.0-preview.3-512-g66767aa54ee1659ea02f65f12b4af95c807af140
OS                             Microsoft Windows 10.0.19045
Platform                       Win32NT
PSCompatibleVersions           {1.0, 2.0, 3.0, 4.0…}
PSRemotingProtocolVersion      2.3
SerializationVersion           <IP_ADDRESS>
WSManStackVersion              3.0

Visuals
No response

(a) This Repo won't process fixes to bugs in in PowerShell 5
(b) I Can't repro the this
(c) sort-object {script block} will evaluate a the script block as a the sort property - normally  the script block contains $_ but that you have is "sort by a constant", which doesn't guarantee output order = input order and which is what pwsh7 gives you e.g.  @(1..9)|sort-object {1}  isn't sorted.
(d) There are some very subtle changes to sort order with culture changes between different versions of .NET used in different versions of PowerShell.

@H4de5-7

@(1..9)|sort-object {1}

Not sure what  you trying to do here as your calculated property is a static value and therefore there isn't any way for the Sort-Object cmdlet to prioritize one object above (or below) the other. What does appear here, is that apparently the older 5.1 Sort-Object cmdlet does index the items (probably with a unordered hashtable), something similar to:
$List = 1..9 | % { [PSCustomObject]@{ a = 1; b = $_ } }

Windows-PowerShell 5.1
$List | Sort-Object 'a'

a b
- -
1 7
1 6
1 9
1 8
1 5
1 2
1 1
1 4
1 3

PowerShell (Core) 7:
$List | Sort-Object 'a'

a b
- -
1 1
1 2
1 3
1 4
1 5
1 6
1 7
1 8
1 9


Made lastSyncTime optional on GeoReplication

lastSyncTime is listed as a required parameter in swagger. This causes some live tests to fail with deserialization errors as it is actually optional for the service to return it. Added a readme transform to make the field optional, hopefully mitigating the failing tests

/azp run java - storage - tests

API change check for com.azure:azure-storage-blob
API changes are not detected in this pull request for com.azure:azure-storage-blob

Closing as running the live test pipeline revealed this is not the solution. See #28624


Jetpack Compose Intergration

Describe the feature that you would like added
Using Jetpack Compose to draw Fluent UI
What component or utility would this be added to
Prob everything
Have you discussed this feature with our team, and if so, who
No
Additional context/screenshots
Google announced that Jetpack Compose will be the future of the Android UI toolkit, I think there should be a Jetpack Compose version of Fluent UI
Also, Jetpack Compose is cross-platform and supports desktop. Single integration will work on multiple platforms, it is cool.

Hi there,
any update on this issue? :)

We are working on to creating components using jetpack compose and have actually released first version with Button and FAB. Release Link: https://github.com/microsoft/fluentui-android/releases/tag/0.1.0
FluentUI will be coming up with more controls over the next few months.

Thank!

@NamanPandey I think it would be better to separate compose implementation from originals. Jetpack compose is multiplatform, which means we can bring fluentui to other platforms, not only android.


Parameter replacement does not work.

Is this a bug or a feature?
I think this
if Object.keys(args).length == 0 then ret else @replaceParams label, args
should be this
if Object.keys(args).length == 0 then ret else @replaceParams ret, args

thanks for the catch and your fix


PubSub: Sub client not retrieving message again if it doesn't ack

I'm experiencing an issue where messages are not retrieved again when a message is not ack'ed.
In the below code, the self.sub is opened and the main thread sleeps. When the process method fails, the message is not ack'ed and I am expecting it to be resent in the ack deadline of the subscription (10 seconds this case). However, the message is never receieved again in this subclient, unless I completely restart the subclient and open a new callback on the same subscription. The subscription continues to listen to new messages though.
In other threads (such as this one https://github.com/GoogleCloudPlatform/google-cloud-python/issues/4615) and in the docs, it mentions using future.result() or future.exception(), but both of these just block and never show a problem has occured.
What is the best way to fix this sort of problem? Additionally, is there a way to get the error to propagate?
A snippet:
import random

from google import auth
from google.auth import exceptions
from google.auth.credentials import AnonymousCredentials
from google.cloud import pubsub

class TestProcessor:

    def process_message(self, message):
        print('processing...')
        if random.randint(0, 1): # Some unforeseen error
            raise ValueError
        print(message)
        message.ack()

class GoogleSubClient:

    def __init__(self, project_id, topic, subscription, message_processor, max_messages=10):
        try:
            credentials, _ = auth.default()
        except exceptions.DefaultCredentialsError:  # For running on emulator
            credentials = AnonymousCredentials()
        self._subscriber = pubsub.SubscriberClient(credentials=credentials)
        self.sub = None
        self.future = None
        self._flow = pubsub.types.FlowControl(max_messages=max_messages)
        self._topic = self._subscriber.topic_path(project=project_id, topic=topic)
        self._subscription = self._subscriber.subscription_path(project=project_id, subscription=subscription)
        self._message_processor = message_processor

    def run(self):
        self.sub = self._subscriber.subscribe(subscription=self._subscription, flow_control=self._flow)
        self.future = self.sub.open(self._message_processor.process_message)

pubsub version:
Name: google-cloud-pubsub
Version: 0.32.0

@kir-titievsky is this expected behavior?
I have a hunch that because we manage leasing messages, a top-level exception means that the client holds onto the message indefinitely.

Right -- since neither the ack nor a nack would ever get called.  If you restart the client, there is no longer anything extending the leases and messages are eventually re-delivered.
So the "solution" is to:

        if random.randint(0, 1): # Some unforeseen error
            message.nack()
            raise ValueError

Is there a better way to handle errors more generically?  Meaning always call message.nack() on callback failure?
We have a solution posted here: https://cloud.google.com/pubsub/docs/pull#subscriber-error-listener-python but now that I look at it, it appears that may not work.

Yeah we can actually wrap the user callback in something like this:
try:
    user_callback(message)
except Exception:
    message.nack()
    raise

If you think that's the right behavior?

I do.  Otherwise messages get stuck.  I wonder if we need to do something like this in other client libraries.  @mdietz94, thoughts?

I believe we already do this, certainly it's how we did things in Java.

Thanks for the quick responses.
Adding something like:
class GoogleSubClient:

    def __init__(self, project_id, topic, subscription, message_processor, max_messages=10):
        try:
            credentials, _ = auth.default()
        except exceptions.DefaultCredentialsError:  # For running on emulator
            credentials = AnonymousCredentials()
        self._subscriber = pubsub.SubscriberClient(credentials=credentials)
        self.sub = None
        self.future = None
        self._flow = pubsub.types.FlowControl(max_messages=max_messages)
        self._topic = self._subscriber.topic_path(project=project_id, topic=topic)  # pylint: disable=no-member
        self._subscription = self._subscriber.subscription_path(project=project_id, subscription=subscription)  # pylint: disable=no-member
        self._message_processor = message_processor

    def callback_wrapper(self, message):
        try:
            self._message_processor.process_message(message)
        except Exception:
            message.nack()
            raise  # Or maybe just log this, otherwise we don't see it

    def run(self):
        self.sub = self._subscriber.subscribe(subscription=self._subscription, flow_control=self._flow)
        self.future = self.sub.open(self.callback_wrapper)

Into the subclient by wrapping the callback, fixes the issue of redelivery on exception. However, the redelivery also doesn't occur if message.ack() isn't called at all, or isn't called for > messageAckTime.
If the change the processor to:
class TestProcessor:

    @staticmethod
    def process_message(message):
        print('processing...')
        if random.randint(0, 1):
            time.sleep(100)
        print(message)
        message.ack()

The messages are not redelivered in that sleep time, which is something (maybe incorrectly) that I would expect.

You should not expect that. Potentially we want a max processing time after
which we stop mod asking in case we leak the ack handler, but that should
be several hours. We have users that take an hour to process each message.
On Fri, Mar 9, 2018, 5:15 AM liam-j-bennett<EMAIL_ADDRESS>wrote:

Thanks for the quick responses.
Adding something like:
class GoogleSubClient:
def __init__(self, project_id, topic, subscription, message_processor, max_messages=10):
    try:
        credentials, _ = auth.default()
    except exceptions.DefaultCredentialsError:  # For running on emulator
        credentials = AnonymousCredentials()
    self._subscriber = pubsub.SubscriberClient(credentials=credentials)
    self.sub = None
    self.future = None
    self._flow = pubsub.types.FlowControl(max_messages=max_messages)
    self._topic = self._subscriber.topic_path(project=project_id, topic=topic)  # pylint: disable=no-member
    self._subscription = self._subscriber.subscription_path(project=project_id, subscription=subscription)  # pylint: disable=no-member
    self._message_processor = message_processor

def callback_wrapper(self, message):
    try:
        self._message_processor.process_message(message)
    except Exception:
        message.nack()
        raise  # Or maybe just log this, otherwise we don't see it

def run(self):
    self.sub = self._subscriber.subscribe(subscription=self._subscription, flow_control=self._flow)
    self.future = self.sub.open(self.callback_wrapper)

Into the subclient by wrapping the callback, fixes the issue of redelivery
on exception. However, the redelivery also doesn't occur if message.ack()
isn't called at all, or isn't called for > messageAckTime.
If the change the processor to:
class TestProcessor:
@staticmethod
def process_message(message):
    print('processing...')
    if random.randint(0, 1):
        time.sleep(100)
    print(message)
    message.ack()

The messages are not redelivered in that sleep time, which is something
(maybe incorrectly) that I would expect.
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5005#issuecomment-371771576,
or mute the thread
https://github.com/notifications/unsubscribe-auth/ABvXagjHXCEg0W0LKgRtrHPHAkZkd8M7ks5tclYogaJpZM4SjBiY
.

Yeah, so messageAckTime doesn't necessary mean that it will be redelivered after that. The subscriber "leases" the messages it receives and calls modify ack deadline on them in the background.
So it seems there's two actionable items here:

We need to wrap the callback in an error handler to nack them.
We need to have some sort of overall deadline where we nack messages instead of leasing them indefinitely.  (Should this be configurable?)

@kir-titievsky @mdietz94 does that sounds right to y'all?

Yes. 2 should definitely be configurable, with a default maybe of 2 hours
On Fri, Mar 9, 2018, 12:08 PM Jon Wayne Parrott<EMAIL_ADDRESS>wrote:

Yeah, so messageAckTime doesn't necessary mean that it will be
redelivered after that. The subscriber "leases" the messages it receives
and calls modify ack deadline on them in the background.
So it seems there's two actionable items here:

We need to wrap the callback in an error handler to nack them.
We need to have some sort of overall deadline where we nack
messages instead of leasing them indefinitely. (Should this be
configurable?)

@kir-titievsky https://github.com/kir-titievsky @mdietz94
https://github.com/mdietz94 does that sounds right to y'all?
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5005#issuecomment-371876996,
or mute the thread
https://github.com/notifications/unsubscribe-auth/ABvXavTd1WHQ6HnjbTYKykjoxA_OVa0zks5tcrcbgaJpZM4SjBiY
.

amen to all, except that it's not obvious to me how I change the max lease
deadline.
On Fri, Mar 9, 2018 at 12:15 PM Max Dietz<EMAIL_ADDRESS>wrote:

Yes. 2 should definitely be configurable, with a default maybe of 2 hours
On Fri, Mar 9, 2018, 12:08 PM Jon Wayne Parrott<EMAIL_ADDRESS>wrote:

Yeah, so messageAckTime doesn't necessary mean that it will be
redelivered after that. The subscriber "leases" the messages it receives
and calls modify ack deadline on them in the background.
So it seems there's two actionable items here:

We need to wrap the callback in an error handler to nack them.
We need to have some sort of overall deadline where we nack
messages instead of leasing them indefinitely. (Should this be
configurable?)

@kir-titievsky https://github.com/kir-titievsky @mdietz94
https://github.com/mdietz94 does that sounds right to y'all?
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
<
https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5005#issuecomment-371876996
,
or mute the thread
<
https://github.com/notifications/unsubscribe-auth/ABvXavTd1WHQ6HnjbTYKykjoxA_OVa0zks5tcrcbgaJpZM4SjBiY
.

—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5005#issuecomment-371879049,
or mute the thread
https://github.com/notifications/unsubscribe-auth/ARrMFlYrkmuLTNdMcYrSNYCI2OrJ935oks5tcriqgaJpZM4SjBiY
.

--
Kir Titievsky | Product Manager | Google Cloud Pub/Sub
https://cloud.google.com/pubsub/overview

I'm guessing it makes the most sense to add yet another flow control setting.


python310Packages.python-arango: 7.8.0 -> 7.8.1

Automatic update generated by nixpkgs-update tools. This update was made based on information from passthru.updateScript.
meta.description for python310Packages.python-arango is: Python Driver for ArangoDB
meta.homepage for python310Packages.python-arango is: https://github.com/ArangoDB-Community/python-arango
meta.changelog for python310Packages.python-arango is: https://github.com/ArangoDB-Community/python-arango/releases/tag/7.8.1
Updates performed

Ran passthru.UpdateScript

To inspect upstream changes
Impact

Checks done (click to expand)

built on NixOS
The tests defined in passthru.tests, if any, passed
found 7.8.1 with grep in /nix/store/g0qqjhpb1i74rl3mi2zhdrpmvb32k09d-python3.10-python-arango-7.8.1
found 7.8.1 in filename of file in /nix/store/g0qqjhpb1i74rl3mi2zhdrpmvb32k09d-python3.10-python-arango-7.8.1

Rebuild report (if merged into master) (click to expand)

2 total rebuild path(s)

2 package rebuild(s)

First fifty rebuilds by attrpath
python310Packages.python-arango
python311Packages.python-arango

Instructions to test this update (click to expand)

Either download from Cachix:
nix-store -r /nix/store/g0qqjhpb1i74rl3mi2zhdrpmvb32k09d-python3.10-python-arango-7.8.1 \
  --option binary-caches 'https://cache.nixos.org/ https://nix-community.cachix.org/' \
  --option trusted-public-keys '
  nix-community.cachix.org-1:mB9FSh9qf2dCimDSUo8Zy7bkq5CX+/rkCWyvRCYg3Fs=
  cache.nixos.org-1:6NCHdD59X431o0gWypbMrAURkbJ16ZPMQFGspcDShjY=
  '

(The Cachix cache is only trusted for this store-path realization.)
For the Cachix download to work, your user must be in the trusted-users list or you can use sudo since root is effectively trusted.
Or, build yourself:
nix-build -A python310Packages.python-arango https://github.com/r-ryantm/nixpkgs/archive/1e74c982ae8494fcf5f92638e8db1afd2dfb500c.tar.gz

Or:
nix build github:r-ryantm/nixpkgs/1e74c982ae8494fcf5f92638e8db1afd2dfb500c#python310Packages.python-arango

After you've downloaded or built it, look at the files and if there are any, run the binaries:
ls -la /nix/store/g0qqjhpb1i74rl3mi2zhdrpmvb32k09d-python3.10-python-arango-7.8.1
ls -la /nix/store/g0qqjhpb1i74rl3mi2zhdrpmvb32k09d-python3.10-python-arango-7.8.1/bin

Pre-merge build results
We have automatically built all packages that will get rebuilt due to
this change.
This gives evidence on whether the upgrade will break dependent packages.
Note sometimes packages show up as failed to build independent of the
change, simply because they are already broken on the target branch.
Result of nixpkgs-review run on x86_64-linux 1

2 packages built:

python310Packages.python-arango
python311Packages.python-arango

Maintainer pings
cc @jsoo1 for testing.

Already on staging-next.


Increment version for C SDK releases

Increment version for C SDK releases

@danieljurek - can we merge this?


Add files via upload

All marker files are uploaded on my repository, ready, except for Earth, they will take a little longer.

What are these marker files for? Is this PR still relevant after all this time?

@Arvil17 pinging for attention to @dbeachy1's question.


MDRectangleFlatButton Line_Color Bug

Description of the Bug
When a MDRectangleFlat button is disabled and then activated, the line_color loses functionality. So even after enabling it, you cannot set the line_color to what you want, it wont update.
Code and Logs
from kivy.app import App
from kivy.lang import Builder

kv = """
       MDRectangleFlatButton:
            id: okaction
            font_style: "Button"
            theme_text_color: "Custom"
            pos_hint: {"center_x": 0.5, "center_y": 0.5}
            line_color: C("FFFFFF")
            text_color: C("FFFFFF")
            text: "End Turn"
            disabled: True
"""

self.ids.okaction.disabled = False

Versions

OS: Windows 10
Python: 3.9
Kivy: 2.0.0
KivyMD: 1.0.0.dev0 Master

I am still having this issue.

@Trenix Update the KivyMD library from the master branch.

@Trenix Update the KivyMD library from the master branch.

I'm almost certain that I have. Is it working on your end?
from kivy.lang import Builder
from kivymd.uix.screen import MDScreen

KV = """
#:import C kivy.utils.get_color_from_hex

ScreenManager:
    MainInfo:

<MainInfo>:
    name: "maininfo"
    spacing: "8dp"
    md_bg_color: C('#000000')

    MDBoxLayout:

        MDRectangleFlatButton:
            id: okaction
            font_style: "Button"
            theme_text_color: "Custom"
            pos_hint: {"center_x": 0.5, "center_y": 0.5}
            line_color: C("FFFFFF")
            text_color: C("FFFFFF")
            text: "End Turn"
            disabled: True
            on_release:
                self.disabled = False

        MDRectangleFlatButton:
            font_style: "Button"
            theme_text_color: "Custom"
            pos_hint: {"center_x": 0.5, "center_y": 0.5}
            line_color: C("FFFFFF")
            text_color: C("FFFFFF")
            text: "End Turn"
            on_release:
                root.fix()
"""

class MainInfo(MDScreen):
    def fix(self):
        self.ids.okaction.disabled = False

class MainApp(MDApp):
    def build(self):
        screen = Builder.load_string(KV)
        return screen

MainApp().run()

``

So there are two buttons. On button activates the other button which was originally disabled. When enabled, the line_color for the button was got enabled, remains as the disabled_color. It cannot be changed. Once a button is disabled and then enabled, the line color cannot be changed, it remains as the disabled_color.

@Trenix Your code example does not demonstrate this...

Can you take a picture on your end of what is the result? I'm certain I have the latest commit.

@Trenix

I did a clean reinstall of kivymd master and it fixed it. Thanks!


Support workflow metadata query

Is your feature request related to a problem? Please describe.
Currently, it is not possible to get a list of queries and signals a workflow is listening on. So UI has to emit an unsupported query and parse the list of supported ones from the message.
Describe the solution you'd like
Add a query that would return metadata about workflow. Lists of supported queries and signals should be included into the result.
Describe alternatives you've considered
Use worker query (not implemented yet) instead. But as the set of queries and signals that workflow accepts is dynamic a normal query would make more sense.
Additional context
An error is logged by the service every time UI needs to find out the list of supported queries.
The query should be supported by all SDKs.

See https://github.com/temporalio/features/issues/51


Global disabling of all graphics

One of the issues I found when testing on Travis ( #37), and also when running Netpyne scripts remotely was that matplotlib was required, and that some graphical elements were initialised leading to errors related to no display for windows.
It would be great to be able to set one global variable in netpyne to say: ignore all plotting etc. and don't even try to import matplotlib etc. This would allow scripts such as this:  https://github.com/Neurosim-lab/netpyne/blob/master/examples/HHTut/HHTut_run.py to search for a command line arg (-nogui) and set that one global variable in netpyne, as opposed to individually disabling gui elements, e.g. https://github.com/OpenSourceBrain/NetPyNEShowcase/blob/master/NetPyNE/HHSmall/HH_run.py

@pgleeson:
You can now do this to disable graphics:
import netpyne
netpyne.gui = False


feat/add-replace-param-props-codemod

https://linear.app/codemod/issue/CDMD-2461/[codemod-new]-replace-param-prop

let's add some more test cases


Remove interactive widgets

Related to #194

Codecov Report
All modified and coverable lines are covered by tests :white_check_mark:

Project coverage is 98.42%. Comparing base (bf31eaf) to head (8a705ff).

Additional details and impacted files
@@           Coverage Diff           @@
##             main     #358   +/-   ##
=======================================
  Coverage   98.42%   98.42%
=======================================
  Files          30       30
  Lines        3051     3051
=======================================
  Hits         3003     3003
  Misses         48       48

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.


Adds Enhancements

Refer to Trello card "Growth Curve Projects: Enhancements"

Merged upon review during 8/28 meeting


Minor fix to show usable error message

Minor fix to show usable error message. Relates to https://github.com/trydionel/git-pivotal/issues/28

Hi Robert,
Can you add a quick test for this before we merge it in?
Thanks!


[Minor] Add Task Level Metric & Script

This PR:

adds task level metric logging including input read time, computation time, output write time, and output written bytes.
adds an option to calculate the min, mean, max, and total of each logged metric for every IR vertices.

The result of this option for our default MR IT case log is like below:

@junggil updated the arrangement of output indentation. Thanks!

@wonook The metrics I've added here are logged in the main thread of TaskGroupExecutor, but sent to the driver through separate thread (please check MetricManagerWorker).

@sanha This PR seems like it produces a mysterious metric.log file under examples/beam after running tests. Can you prevent this from happening?


Inspector crash

What happened
Create new app, enable inspector, select top node in widget tree, and then move selection down in the tree with arrow down about 20 times
Version information
Android Studio `3.0.1` • Flutter plugin `io.flutter 20.0.1` • Dart plugin `171.4424`

Flutter • channel master • https://github.com/flutter/flutter.git
Framework • revision 7766b2a196 (4 hours ago) • 2017-12-20 15:13:34 +0100
Engine • revision 718bda0c9c
Tools • Dart 1.25.0-dev.11.0

Exception
Error evaluating expression:
Unhandled exception:
Build scheduled during frame.
While the widget tree was being built, laid out, and painted, a new frame was scheduled to rebuild the widget tree. This might be because setState() was called from a layout or paint callback. If a change is needed to the widget tree, it should be applied as the tree is being built. Scheduling a change for the subsequent frame instead results in an interface that lags behind by one frame. If this was done to make your build dependent on a size measured at layout time, consider using a LayoutBuilder, CustomSingleChildLayout, or CustomMultiChildLayout. If, on the other hand, the one frame delay is the desired effect, for example because this is an animation, consider scheduling the frame in a post-frame callback using SchedulerBinding.addPostFrameCallback or using an AnimationController to trigger the animation.
#0      BindingBase&GestureBinding&ServicesBinding&SchedulerBinding&PaintingBinding&RendererBinding&WidgetsBinding._handleBuildScheduled.<anonymous closure> (package:flutter/src/widgets/binding.dart:506:9)
#1      BindingBase&GestureBinding&ServicesBinding&SchedulerBinding&PaintingBinding&RendererBinding&WidgetsBinding._handleBuildScheduled (package:flutter/src/widgets/binding.dart:525:6)
#2      BuildOwner.scheduleBuildFor (package:flutter/src/widgets/framework.dart:2077:23)
#3      Element.markNeedsBuild (package:flutter/src/widgets/framework.dart:3416:11)
#4      State.setState (package:flutter/src/widgets/framework.dart:1101:14)
#5      _WidgetInspectorState.initState.<anonymous closure> (package:flutter/src/widgets/widget_inspector.dart:474:7)
#6      WidgetInspectorService.setSelection (package:flutter/src/widgets/widget_inspector.dart:284:33)
#7      WidgetInspectorService.setSelectionById (package:flutter/src/widgets/widget_inspector.dart:260:12)
#8      Eval (evaluate:source:1:39)
#9      Eval (evaluate:source:1:4)
#10     new ImageConfiguration (package:flutter/src/painting/image_provider.dart:40:5)
#11     ImageConfiguration.copyWith (package:flutter/src/painting/image_provider.dart:54:16)
#12     RenderDecoratedBox.paint (package:flutter/src/rendering/proxy_box.dart:1576:66)
#13     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#14     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#15     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#16     RenderFractionalTranslation.paint (package:flutter/src/rendering/proxy_box.dart:2039:18)
#17     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#18     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#19     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#20     RenderFractionalTranslation.paint (package:flutter/src/rendering/proxy_box.dart:2039:18)
#21     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#22     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#23     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#24     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#25     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#26     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#27     RenderOffstage.paint (package:flutter/src/rendering/proxy_box.dart:2452:16)
#28     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#29     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#30     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#31     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#32     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#33     RenderBox&ContainerRenderObjectMixin&RenderBoxContainerDefaultsMixin.defaultPaint (package:flutter/src/rendering/box.dart:2183:15)
#34     RenderStack.paintStack (package:flutter/src/rendering/stack.dart:580:5)
#35     RenderStack.paint (package:flutter/src/rendering/stack.dart:588:7)
#36     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#37     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#38     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#39     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#40     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#41     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#42     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#43     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#44     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#45     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#46     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#47     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#48     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#49     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#50     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#51     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#52     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#53     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#54     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#55     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#56     RenderBox&ContainerRenderObjectMixin&RenderBoxContainerDefaultsMixin.defaultPaint (package:flutter/src/rendering/box.dart:2183:15)
#57     RenderStack.paintStack (package:flutter/src/rendering/stack.dart:580:5)
#58     RenderStack.paint (package:flutter/src/rendering/stack.dart:588:7)
#59     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#60     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#61     RenderBox&RenderObjectWithChildMixin&RenderProxyBoxMixin.paint (package:flutter/src/rendering/proxy_box.dart:123:15)
#62     RenderCustomPaint.paint (package:flutter/src/rendering/custom_paint.dart:559:16)
#63     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#64     PaintingContext.paintChild (package:flutter/src/rendering/object.dart:136:13)
#65     RenderView.paint (package:flutter/src/rendering/view.dart:173:15)
#66     RenderObject._paintWithContext (package:flutter/src/rendering/object.dart:1999:7)
#67     PaintingContext.repaintCompositedChild (package:flutter/src/rendering/object.dart:116:11)
#68     PipelineOwner.flushPaint (package:flutter/src/rendering/object.dart:784:29)
#69     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding&PaintingBinding&RendererBinding.drawFrame (package:flutter/src/rendering/binding.dart:272:19)
#70     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding&PaintingBinding&RendererBinding&WidgetsBinding.drawFrame (package:flutter/src/widgets/binding.dart:612:22)
#71     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding&PaintingBinding&RendererBinding._handlePersistentFrameCallback (package:flutter/src/rendering/binding.dart:208:5)
#72     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding._invokeFrameCallback (package:flutter/src/scheduler/binding.dart:921:15)
#73     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding.handleDrawFrame (package:flutter/src/scheduler/binding.dart:861:9)
#74     BindingBase&GestureBinding&ServicesBinding&SchedulerBinding._handleDrawFrame (package:flutter/src/scheduler/binding.dart:773:5)
#75     _invoke (file:///b/build/slave/Mac_Engine/build/src/flutter/lib/ui/hooks.dart:120)
#76     _drawFrame (file:///b/build/slave/Mac_Engine/build/src/flutter/lib/ui/hooks.dart:109)

com.intellij.openapi.diagnostic.Logger$EmptyThrowable
   at com.intellij.openapi.diagnostic.Logger.error(Logger.java:134)
   at io.flutter.inspector.EvalOnDartLibrary$1.received(EvalOnDartLibrary.java:98)
   at org.dartlang.vm.service.VmService.forwardResponse(VmService.java:410)
   at org.dartlang.vm.service.VmServiceBase.processResponse(VmServiceBase.java:432)
   at org.dartlang.vm.service.VmServiceBase$1.onMessage(VmServiceBase.java:99)
   at de.roderick.weberknecht.WebSocketReceiver.run(WebSocketReceiver.java:65)

cc @jacob314

This has been fixed for a couple months.


Option To Always Import Classes

It would be nice to have an option to always import classes in the generated code. So instead of having this:
@return \My\Module\Generated\StructType\MyType

Import the type and then just have this:
@return MyType

Indeed, I implicitely noted it in the issue #233 as Group use statements on top of the class for every used class not in the same namespace


Add path param to endpoint

Hello @hahwul,
When you have time, I would appreciate it if you could review this.
Have a great Chuseok!!
Resolve: #389
Output
Below is the output after the changes have been applied:

When Using the --set-pvalue=test Flag
Here is the output when the --set-pvalue=test flag is set:

Additional Suggestion:
Currently, the --set-pvalue flag is applied to the values of all parameters.
IMAO, It might be better to enhance this option to allow specifying the value for a particular parameter by its key.

@ksg97031
Wow, great work!!

@ksg97031 그리고 즐거운 추석 보내세요 :D