Commit 6d814c37 authored by Przemyslaw Kaminski's avatar Przemyslaw Kaminski

[Graph] more graph async work

parent e3090ae8
...@@ -104,11 +104,11 @@ getGraph uId nId = do ...@@ -104,11 +104,11 @@ getGraph uId nId = do
g <- case graph of g <- case graph of
Nothing -> do Nothing -> do
graph' <- computeGraph cId NgramsTerms repo graph' <- computeGraph cId NgramsTerms repo
_ <- insertGraph cId uId' (HyperdataGraph $ Just graph') _ <- insertGraph cId uId' (HyperdataGraph $ Just graph')
pure graph' pure $ trace "Graph empty, computing" $ graph'
Just graph' -> pure graph' Just graph' -> pure $ trace "Graph exists, returning" $ graph'
-- Just graph' -> if listVersion == Just v -- Just graph' -> if listVersion == Just v
-- then pure graph' -- then pure graph'
...@@ -147,14 +147,14 @@ recomputeGraph uId nId = do ...@@ -147,14 +147,14 @@ recomputeGraph uId nId = do
Nothing -> do Nothing -> do
graph' <- computeGraph cId NgramsTerms repo graph' <- computeGraph cId NgramsTerms repo
_ <- insertGraph cId uId' (HyperdataGraph $ Just graph') _ <- insertGraph cId uId' (HyperdataGraph $ Just graph')
pure graph' pure $ trace "[recomputeGraph] Graph empty, computing" $ graph'
Just graph' -> if listVersion == Just v Just graph' -> if listVersion == Just v
then pure graph' then pure graph'
else do else do
graph'' <- computeGraph cId NgramsTerms repo graph'' <- computeGraph cId NgramsTerms repo
_ <- updateHyperdata nId (HyperdataGraph $ Just graph'') _ <- updateHyperdata nId (HyperdataGraph $ Just graph'')
pure graph'' pure $ trace "[recomputeGraph] Graph exists, recomputing" $ graph''
newGraph <- liftIO newEmptyMVar newGraph <- liftIO newEmptyMVar
_ <- liftIO $ forkIO $ putMVar newGraph g _ <- liftIO $ forkIO $ putMVar newGraph g
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment