Documentation

Fields

• workerId :: UUID
   
• modelContext :: ModelContext
   
• frameworkConfig :: FrameworkConfig
   
• pgListener :: PGListener
   

Fields

• dispatcher :: (ReleaseKey, Async ())
   
• subscription :: Subscription
   
• pollerReleaseKey :: ReleaseKey
   
• action :: TBQueue JobWorkerProcessMessage
   
• staleRecoveryReleaseKey :: Maybe ReleaseKey
   
• activeCount :: TVar Int
   
• isStopping :: TVar Bool

  Set when the worker process is shutting down. Dispatchers stop accepting queued work and active workers stop fetching another job.