From bd0ddaabbe826137231574f964e33d2d6674c599 Mon Sep 17 00:00:00 2001 From: Piotr Bandurski Date: Thu, 10 Jun 2021 15:33:46 +0200 Subject: [PATCH] fix entities cache refresh --- .../tech/cryptonomic/conseil/api/metadata/MetadataService.scala | 2 +- .../platform/discovery/GenericPlatformDiscoveryOperations.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/metadata/MetadataService.scala b/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/metadata/MetadataService.scala index 258db806d..05b426e4f 100644 --- a/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/metadata/MetadataService.scala +++ b/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/metadata/MetadataService.scala @@ -30,7 +30,7 @@ class MetadataService( private val entities = { def futureEntities(path: NetworkPath): List[Entity] = - Await.result(platformDiscoveryOperations.getEntities(path), 5 second) + Await.result(platformDiscoveryOperations.getEntities(path), 10 second) networks.values.flatten .map(_.path) diff --git a/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/routes/platform/discovery/GenericPlatformDiscoveryOperations.scala b/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/routes/platform/discovery/GenericPlatformDiscoveryOperations.scala index 65866b5e2..403fbf6c5 100644 --- a/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/routes/platform/discovery/GenericPlatformDiscoveryOperations.scala +++ b/conseil-api/src/main/scala/tech/cryptonomic/conseil/api/routes/platform/discovery/GenericPlatformDiscoveryOperations.scala @@ -191,7 +191,7 @@ class GenericPlatformDiscoveryOperations( updatedEntities <- IO.fromFuture( IO(dbRunner.runQuery(preCacheEntities(networkPath.up.platform, networkPath.network))) ) - _ <- caching.putAllEntities(updatedEntities) + _ <- caching.putEntities(key, updatedEntities(key).value) } yield ()).unsafeRunAsyncAndForget() IO.pure(ent) }