Restart cancelled jobs when needed

1 files changed, 8 insertions, 2 deletions

diff --git a/src/Job.hs b/src/Job.hs
index 7701da0..10fe865 100644
--- a/src/Job.hs
+++ b/src/Job.hs
@@ -226,8 +226,14 @@ runJobs mngr@JobManager {..} tout jobs rerun = do
             managed <- readTVar jmJobs
             ( job, tid, ) <$> case M.lookup (jobId job) managed of
                 Just origVar -> do
-                    newTVar . JobDuplicate (jobId job) =<< readTVar origVar
-
+                    readTVar origVar >>= \case
+                        JobCancelled -> do
+                            -- Restart previously cancelled job
+                            statusVar <- newTVar JobQueued
+                            writeTVar jmJobs $ M.insert (jobId job) statusVar managed
+                            return statusVar
+                        pstatus -> do
+                            newTVar $ JobDuplicate (jobId job) pstatus
                 Nothing -> do
                     statusVar <- newTVar JobQueued
                     writeTVar jmJobs $ M.insert (jobId job) statusVar managed