Skip to content

Commit

Permalink
fix entities cache refresh
Browse files Browse the repository at this point in the history
  • Loading branch information
redroy44 committed Jun 10, 2021
1 parent 3fcf82e commit bd0ddaa
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit bd0ddaa

Please sign in to comment.