Skip to content

haskell-gargantext
haskell-gargantext
Verified Commit ec6d4e91 authored by Przemyslaw Kaminski's avatar Przemyslaw Kaminski
Browse files
Options

[worker] no resendOnKill by default for all jobs

parent 46038100
Pipeline #6920 failed with stages
          in 22 minutes and 11 seconds
          Hide whitespace changes
          Inline Side-by-side
          Showing with 3 additions and 3 deletions
          cabal.project
          View file @ ec6d4e91
          ...@@ -196,7 +196,7 @@ source-repository-package ...@@ -196,7 +196,7 @@ source-repository-package
          source-repository-package source-repository-package
          type: git type: git
          location: https://gitlab.iscpif.fr/gargantext/haskell-bee location: https://gitlab.iscpif.fr/gargantext/haskell-bee
          tag: 307f6760383b74cddd5a586d0b5b1f1a2fc94429 tag: 239a5eca1f11f802f4ae3cc1c80c390f7c6896ac
          source-repository-package source-repository-package
          type: git type: git
          ......
          src/Gargantext/Core/Worker/Jobs.hs
          View file @ ec6d4e91
          ...@@ -48,7 +48,7 @@ sendJob job = do ...@@ -48,7 +48,7 @@ sendJob job = do
          updateJobData :: Job -> W.SendJob PGMQBroker Job -> W.SendJob PGMQBroker Job updateJobData :: Job -> W.SendJob PGMQBroker Job -> W.SendJob PGMQBroker Job
          updateJobData (AddCorpusFormAsync {}) sj = sj { W.timeout = 300 } updateJobData (AddCorpusFormAsync {}) sj = sj { W.timeout = 300 }
          updateJobData (AddCorpusWithQuery {}) sj = sj { W.timeout = 3000 } updateJobData (AddCorpusWithQuery {}) sj = sj { W.timeout = 3000 }
          updateJobData _ sj = sj updateJobData _ sj = sj { W.resendOnKill = False }
          -- | This is just a list of what's implemented and what not. -- | This is just a list of what's implemented and what not.
          ......
          src/Gargantext/Database/Action/Flow.hs
          View file @ ec6d4e91
          ...@@ -280,7 +280,7 @@ flow c mkCorpusUser la mfslw (count, docsC) jobHandle = do ...@@ -280,7 +280,7 @@ flow c mkCorpusUser la mfslw (count, docsC) jobHandle = do
          -- TODO if public insertMasterDocs else insertUserDocs -- TODO if public insertMasterDocs else insertUserDocs
          nlpServer <- view $ nlpServerGet (_tt_lang la) nlpServer <- view $ nlpServerGet (_tt_lang la)
          runConduit $ zipSources (yieldMany ([1..] :: [Int])) docsC runConduit $ zipSources (yieldMany ([1..] :: [Int])) docsC
          .| CList.chunksOf 2 .| CList.chunksOf 5
          .| mapM_C (addDocumentsWithProgress nlpServer userCorpusId) .| mapM_C (addDocumentsWithProgress nlpServer userCorpusId)
          .| sinkNull .| sinkNull
          ......
          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