Control.Concurrent.Capataz.Internal.Worker

This module contains all logic related to error handling when spawning threads to execute Worker sub-routines

Documentation

workerMain :: MonadUnliftIO m => ParentSupervisorEnv m -> WorkerOptions m -> WorkerId -> RestartCount -> m (Worker m)

Decorates the given IO () sub-routine with failure handling

forkWorker :: MonadUnliftIO m => ParentSupervisorEnv m -> WorkerOptions m -> Maybe (WorkerId, RestartCount) -> m (Worker m)

Internal function that forks a worker thread on the Capataz thread; note this is different from the public forkWorker function which sends a message to the capataz loop