Configuring Retries and Failures
Configuring Retries and Failures
- public function getRequiredLeaseTime() — Return the number of seconds this worker needs hold a lease on the task for while it performs work. For most tasks you can leave this at `null`, which will give you a default lease (currently 2 hours).
- public function getMaximumRetryCount() — Return the maximum number of times this task may be retried before it is considered permanently failed. By default, tasks retry indefinitely. You can throw a @{class:PhabricatorWorkerPermanentFailureException} to cause an immediate permanent failure.
- public function getWaitBeforeRetry($task) — Return the number of seconds a task should wait after a failure before retrying. For most tasks you can leave this at `null`, which will give you a short default retry period (currently 60 seconds).
Other Methods
Other Methods
- public function setCurrentWorkerTask($task)
- public function getCurrentWorkerTask()
- public function getCurrentWorkerTaskID()
- abstract protected function doWork()
- final public function __construct($data)
- final protected function getTaskData()
- final protected function getTaskDataValue($key, $default)
- final public function executeTask()
- final public static function scheduleTask($task_class, $data, $options)
- public function renderForDisplay($viewer)
- public static function setRunAllTasksInProcess($all) — Set this flag to execute scheduled tasks synchronously, in the same process. This is useful for debugging, and otherwise dramatically worse in every way imaginable.
- final protected function log($pattern)
- final protected function queueTask($class, $data, $options) — Queue a task to be executed after this one succeeds.
- final protected function getQueuedTasks() — Get tasks queued as followups by @{method:queueTask}.
- final public function flushTaskQueue($defaults) — Schedule any queued tasks, then empty the task queue.
- final public static function awakenTaskIDs($ids) — Awaken tasks that have yielded.
- protected function newContentSource()
- protected function getViewer()
- protected function loadLease($lease_phid)
- protected function loadResource($resource_phid)
- protected function loadOperation($operation_phid)
- protected function loadCommands($target_phid)
- protected function checkLeaseExpiration($lease)
- protected function checkResourceExpiration($resource)
- private function checkObjectExpiration($object)
- protected function yieldIfExpiringLease($lease)
- protected function yieldIfExpiringResource($resource)
- private function yieldIfExpiring($expires)
- protected function isTemporaryException($ex)
- protected function getYieldDurationFromException($ex)
- protected function flushDrydockTaskQueue()
- protected function canReclaimResource($resource)
- protected function reclaimResource($resource, $lease)