PhabricatorWorkerManagementRetryWorkflow.php
1bce9a7f1cd2stable

PhabricatorWorkerManagementRetryWorkflow.php
View Options

			<?php

			final class PhabricatorWorkerManagementRetryWorkflow
			extends PhabricatorWorkerManagementWorkflow {

			protected function didConstruct() {
			$this
			->setName('retry')
			->setExamples('retry --id __id__')
			->setSynopsis(
			pht(
			'Retry selected tasks which previously failed permanently or '.
			'were cancelled. Only archived tasks can be retried.'))
			->setArguments(
			array_merge(
			array(
			array(
			'name' => 'repeat',
			'help' => pht(
			'Repeat tasks which already completed successfully.'),
			),
			),
			$this->getTaskSelectionArguments()));
			}

			public function execute(PhutilArgumentParser $args) {
			$console = PhutilConsole::getConsole();
			$tasks = $this->loadTasks($args);

			$is_repeat = $args->getArg('repeat');
			foreach ($tasks as $task) {
			if (!$task->isArchived()) {
			$console->writeOut(
			"<bg:yellow> %s </bg> %s\n",
			pht('ACTIVE'),
			pht(
			'%s is already in the active task queue.',
			$this->describeTask($task)));
			continue;
			}

			$result_success = PhabricatorWorkerArchiveTask::RESULT_SUCCESS;
			if ($task->getResult() == $result_success) {
			if (!$is_repeat) {
			$console->writeOut(
			"<bg:yellow> %s </bg> %s\n",
			pht('SUCCEEDED'),
			pht(
			'%s has already succeeded, and will not be repeated. '.
			'Use "--repeat" to repeat successful tasks.',
			$this->describeTask($task)));
			continue;
			}
			}

			$task->unarchiveTask();

			$console->writeOut(
			"<bg:green> %s </bg> %s\n",
			pht('QUEUED'),
			pht(
			'%s was queued for retry.',
			$this->describeTask($task)));
			}

			return 0;
			}

			}