Copyright | (c) digitally induced GmbH 2020 |
---|---|
Safe Haskell | None |
IHP.Job.Runner
Description
Documentation
runJobWorkers :: [JobWorker] -> Script Source #
worker :: forall job. (job ~ GetModelByTableName (GetTableName job), FilterPrimaryKey (GetTableName job), FromRow job, Show (PrimaryKey (GetTableName job)), FromField (PrimaryKey (GetTableName job)), KnownSymbol (GetTableName job), SetField "attemptsCount" job Int, SetField "lockedBy" job (Maybe UUID), SetField "status" job JobStatus, SetField "updatedAt" job UTCTime, HasField "attemptsCount" job Int, SetField "lastError" job (Maybe Text), Job job, CanUpdate job, Show job) => JobWorker Source #
jobWorkerFetchAndRunLoop :: forall job. (job ~ GetModelByTableName (GetTableName job), FilterPrimaryKey (GetTableName job), FromRow job, Show (PrimaryKey (GetTableName job)), FromField (PrimaryKey (GetTableName job)), KnownSymbol (GetTableName job), SetField "attemptsCount" job Int, SetField "lockedBy" job (Maybe UUID), SetField "status" job JobStatus, SetField "updatedAt" job UTCTime, HasField "attemptsCount" job Int, SetField "lastError" job (Maybe Text), Job job, CanUpdate job, Show job) => JobWorkerArgs -> IO (Async ()) Source #