[flow] report doc count when uploading file

This fixes
#478
There was no `markStarted` and so 'remaining' was always at 0, so the
frontend thought the job was done, even though it was getting
notification about 'succeeded' in that job increasing
parent d19839d8
Pipeline #7661 passed with stages
in 37 minutes and 28 seconds
...@@ -257,6 +257,8 @@ addToCorpusWithTempFile user cid nwtf jobHandle = do ...@@ -257,6 +257,8 @@ addToCorpusWithTempFile user cid nwtf jobHandle = do
-- TODO Add progress (jobStatus) update for docs - this is a -- TODO Add progress (jobStatus) update for docs - this is a
-- long action -- long action
markStarted (fromIntegral count) jobHandle
let docsC' = zipSources (yieldMany [1..]) (transPipe liftBase docsC) let docsC' = zipSources (yieldMany [1..]) (transPipe liftBase docsC)
.| mapMC (\(idx, doc) -> .| mapMC (\(idx, doc) ->
if idx > limit then do if idx > limit then do
......
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