fraport/fradrive
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(jobs): weaken crontab guarantees for performance

Browse Source
This commit is contained in:
Gregor Kleen 2020-12-09 18:11:39 +01:00
parent c65483fb2b
commit 212e316c7e
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Jobs.hs
View File

@ -339,11 +339,12 @@ execCrontab = do
atomically . writeTVar crontabTVar $ Just (now, currentCrontab')
$logDebugS "Crontab" . intercalate "\n" $ "Current crontab:" : map tshow currentCrontab'
let doJob = mapRWST (liftHandler . runDBJobs . setSerializableBatch) $ do
newCrontab <- lift $ hoist lift determineCrontab'
when (newCrontab /= currentCrontab) $
mapRWST (liftIO . atomically) $
liftBase . flip writeTVar newCrontab =<< asks (jobCrontab . jobContext)
let doJob = mapRWST (liftHandler . runDBJobs) $ do
-- newCrontab <- lift $ hoist lift determineCrontab'
-- when (newCrontab /= currentCrontab) $
-- mapRWST (liftIO . atomically) $
-- liftBase . flip writeTVar newCrontab =<< asks (jobCrontab . jobContext)
newCrontab <- atomically . readTVar =<< asks (jobCrontab . jobContext)
mergeState
newState <- State.get