From 7e756985ceacc2311d1629944d847990251fe316 Mon Sep 17 00:00:00 2001 From: Steffen Jost Date: Wed, 6 Sep 2023 14:00:07 +0000 Subject: [PATCH] chore(apc): remove apc processing delay --- src/Jobs/Handler/Print.hs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/Jobs/Handler/Print.hs b/src/Jobs/Handler/Print.hs index 4c97d3f0d..cb16a2907 100644 --- a/src/Jobs/Handler/Print.hs +++ b/src/Jobs/Handler/Print.hs @@ -14,7 +14,7 @@ import Jobs.Queue -- import Jobs.Handler.Intervals.Utils import qualified Data.Text as Text -import UnliftIO.Concurrent (threadDelay) +-- import UnliftIO.Concurrent (threadDelay) -- import Database.Persist.Sql (deleteWhereCount) -- import Database.Esqueleto.Experimental ((:&)(..)) @@ -25,15 +25,15 @@ import UnliftIO.Concurrent (threadDelay) jobPrintAckChunkSize :: Int -jobPrintAckChunkSize = 32 +jobPrintAckChunkSize = 64 -- needed, since JobPrintAck cannot requeue itself due to JobNoQueueSame (and having no parameters) dispatchJobPrintAckAgain :: JobHandler UniWorX dispatchJobPrintAckAgain = JobHandlerException act where - act = do - liftIO $ threadDelay 3e6 -- wait 3s before continuing - void $ queueJob JobPrintAck + act = void $ queueJob JobPrintAck + -- liftIO $ threadDelay 3e6 -- wait 3s before continuing UPDATE: no wait needed + dispatchJobPrintAck :: JobHandler UniWorX dispatchJobPrintAck = JobHandlerException act