PhabricatorTaskmasterDaemon.php
57b898af9a53stable

PhabricatorTaskmasterDaemon.php
View Options

			<?php

			final class PhabricatorTaskmasterDaemon extends PhabricatorDaemon {

			protected function run() {
			do {
			PhabricatorCaches::destroyRequestCache();

			$tasks = id(new PhabricatorWorkerLeaseQuery())
			->setLimit(1)
			->execute();

			if ($tasks) {
			$this->willBeginWork();

			foreach ($tasks as $task) {
			$id = $task->getID();
			$class = $task->getTaskClass();

			$this->log(pht('Working on task %d (%s)...', $id, $class));

			$task = $task->executeTask();
			$ex = $task->getExecutionException();
			if ($ex) {
			if ($ex instanceof PhabricatorWorkerPermanentFailureException) {
			throw new PhutilProxyException(
			pht('Permanent failure while executing Task ID %d.', $id),
			$ex);
			} else if ($ex instanceof PhabricatorWorkerYieldException) {
			$this->log(pht('Task %s yielded.', $id));
			} else {
			$this->log(pht('Task %d failed!', $id));
			throw new PhutilProxyException(
			pht('Error while executing Task ID %d.', $id),
			$ex);
			}
			} else {
			$this->log(pht('Task %s complete! Moved to archive.', $id));
			}
			}

			$sleep = 0;
			} else {
			// When there's no work, sleep for one second. The pool will
			// autoscale down if we're continuously idle for an extended period
			// of time.
			$this->willBeginIdle();
			$sleep = 1;
			}

			$this->sleep($sleep);
			} while (!$this->shouldExit());
			}

			}