From cd7557eb4ab04e903492f01cdda06aa7b42615f1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Roman=20Smr=C5=BE?= Date: Sat, 4 Apr 2026 12:54:30 +0200 Subject: Test: log when a job is enqueued --- src/Job.hs | 1 + src/Output.hs | 4 ++++ 2 files changed, 5 insertions(+) (limited to 'src') diff --git a/src/Job.hs b/src/Job.hs index 9286839..7701da0 100644 --- a/src/Job.hs +++ b/src/Job.hs @@ -266,6 +266,7 @@ runJobs mngr@JobManager {..} tout jobs rerun = do mbStatus -> do when (isJust mbStatus) $ do liftIO $ removeDirectoryRecursive jdir + liftIO $ outputEvent tout $ JobEnqueued (jobId taskJob) uses <- waitForUsedArtifacts tout taskJob results taskStatus runManagedJob mngr taskId (return JobCancelled) $ do liftIO $ atomically $ writeTVar taskStatus JobRunning diff --git a/src/Output.hs b/src/Output.hs index 5fa2f81..e9ce718 100644 --- a/src/Output.hs +++ b/src/Output.hs @@ -42,6 +42,7 @@ data OutputEvent = OutputMessage Text | TestMessage Text | LogMessage Text + | JobEnqueued JobId | JobStarted JobId | JobFinished JobId Text | JobIsDuplicate JobId Text @@ -104,6 +105,9 @@ outputEvent out@Output {..} = liftIO . \case LogMessage msg -> do forM_ outLogs $ \h -> outStrLn out h msg + JobEnqueued jid -> do + forM_ outTest $ \h -> outStrLn out h ("job-enqueue " <> textJobId jid) + JobStarted jid -> do forM_ outLogs $ \h -> outStrLn out h ("Started " <> textJobId jid) forM_ outTest $ \h -> outStrLn out h ("job-start " <> textJobId jid) -- cgit v1.2.3