diff --git a/src/infrastructure/daemon/workers/storage/PhabricatorWorkerActiveTask.php b/src/infrastructure/daemon/workers/storage/PhabricatorWorkerActiveTask.php index 6e3b6ad8fa..36ada93a13 100644 --- a/src/infrastructure/daemon/workers/storage/PhabricatorWorkerActiveTask.php +++ b/src/infrastructure/daemon/workers/storage/PhabricatorWorkerActiveTask.php @@ -135,6 +135,7 @@ final class PhabricatorWorkerActiveTask extends PhabricatorWorkerTask { $this->checkLease(); $did_succeed = false; + $worker = null; try { $worker = $this->getWorkerInstance(); @@ -182,7 +183,11 @@ final class PhabricatorWorkerActiveTask extends PhabricatorWorkerTask { $this->setFailureCount($this->getFailureCount() + 1); $this->setFailureTime(time()); - $retry = $worker->getWaitBeforeRetry($this); + $retry = null; + if ($worker) { + $retry = $worker->getWaitBeforeRetry($this); + } + $retry = coalesce( $retry, PhabricatorWorkerLeaseQuery::getDefaultWaitBeforeRetry());