PhabricatorWorkerTaskDetailController.php
No OneTemporary
Actions

Size

6 KB

Referenced Files

None

Subscribers

None

PhabricatorWorkerTaskDetailController.php
View Options

	<?php

	final class PhabricatorWorkerTaskDetailController
	extends PhabricatorDaemonController {

	public function handleRequest(AphrontRequest $request) {
	$viewer = $request->getViewer();
	$id = $request->getURIData('id');

	$task = id(new PhabricatorWorkerActiveTask())->load($id);
	if (!$task) {
	$tasks = id(new PhabricatorWorkerArchiveTaskQuery())
	->withIDs(array($id))
	->execute();
	$task = reset($tasks);
	}

	$header = new PHUIHeaderView();

	if (!$task) {
	$title = pht('Task Does Not Exist');

	$header->setHeader(pht('Task %d Missing', $id));

	$error_view = new PHUIInfoView();
	$error_view->setTitle(pht('No Such Task'));
	$error_view->appendChild(phutil_tag(
	'p',
	array(),
	pht('This task may have recently been garbage collected.')));
	$error_view->setSeverity(PHUIInfoView::SEVERITY_NODATA);

	$content = $error_view;
	} else {
	$title = pht('Task %d', $task->getID());

	$header->setHeader(
	pht(
	'Task %d: %s',
	$task->getID(),
	$task->getTaskClass()));

	$properties = $this->buildPropertyListView($task);

	$object_box = id(new PHUIObjectBoxView())
	->setHeaderText($title)
	->setBackground(PHUIObjectBoxView::BLUE_PROPERTY)
	->addPropertyList($properties);

	$retry_head = id(new PHUIHeaderView())
	->setHeader(pht('Retries'));

	$retry_info = $this->buildRetryListView($task);

	$retry_box = id(new PHUIObjectBoxView())
	->setHeader($retry_head)
	->setBackground(PHUIObjectBoxView::BLUE_PROPERTY)
	->addPropertyList($retry_info);

	$content = array(
	$object_box,
	$retry_box,
	);
	}

	$header->setHeaderIcon('fa-sort');

	$crumbs = $this->buildApplicationCrumbs();
	$crumbs->addTextCrumb($title);
	$crumbs->setBorder(true);

	$view = id(new PHUITwoColumnView())
	->setHeader($header)
	->setFooter($content);

	return $this->newPage()
	->setTitle($title)
	->setCrumbs($crumbs)
	->appendChild($view);
	}

	private function buildPropertyListView(PhabricatorWorkerTask $task) {
	$viewer = $this->getViewer();

	$view = new PHUIPropertyListView();

	$object_phid = $task->getObjectPHID();
	if ($object_phid) {
	$handles = $viewer->loadHandles(array($object_phid));
	$handle = $handles[$object_phid];
	if ($handle->isComplete()) {
	$view->addProperty(pht('Object'), $handle->renderLink());
	}
	}

	if ($task->isArchived()) {
	switch ($task->getResult()) {
	case PhabricatorWorkerArchiveTask::RESULT_SUCCESS:
	$status = pht('Complete');
	break;
	case PhabricatorWorkerArchiveTask::RESULT_FAILURE:
	$status = pht('Failed');
	break;
	case PhabricatorWorkerArchiveTask::RESULT_CANCELLED:
	$status = pht('Cancelled');
	break;
	default:
	throw new Exception(pht('Unknown task status!'));
	}
	} else {
	$status = pht('Queued');
	}

	$view->addProperty(
	pht('Task Status'),
	$status);

	$view->addProperty(
	pht('Task Class'),
	$task->getTaskClass());

	if ($task->getLeaseExpires()) {
	if ($task->getLeaseExpires() > time()) {
	$lease_status = pht('Leased');
	} else {
	$lease_status = pht('Lease Expired');
	}
	} else {
	$lease_status = phutil_tag('em', array(), pht('Not Leased'));
	}

	$view->addProperty(
	pht('Lease Status'),
	$lease_status);

	$view->addProperty(
	pht('Lease Owner'),
	$task->getLeaseOwner()
	? $task->getLeaseOwner()
	: phutil_tag('em', array(), pht('None')));

	if ($task->getLeaseExpires() && $task->getLeaseOwner()) {
	$expires = ($task->getLeaseExpires() - time());
	$expires = phutil_format_relative_time_detailed($expires);
	} else {
	$expires = phutil_tag('em', array(), pht('None'));
	}

	$view->addProperty(
	pht('Lease Expires'),
	$expires);

	if ($task->isArchived()) {
	$duration = pht('%s us', new PhutilNumber($task->getDuration()));
	} else {
	$duration = phutil_tag('em', array(), pht('Not Completed'));
	}

	$view->addProperty(
	pht('Duration'),
	$duration);

	$data = id(new PhabricatorWorkerTaskData())->load($task->getDataID());
	$task->setData($data->getData());
	$worker = $task->getWorkerInstance();
	$data = $worker->renderForDisplay($viewer);

	if ($data !== null) {
	$view->addProperty(pht('Data'), $data);
	}

	return $view;
	}

	private function buildRetryListView(PhabricatorWorkerTask $task) {
	$view = new PHUIPropertyListView();

	$data = id(new PhabricatorWorkerTaskData())->load($task->getDataID());
	$task->setData($data->getData());
	$worker = $task->getWorkerInstance();

	$view->addProperty(
	pht('Failure Count'),
	$task->getFailureCount());

	$retry_count = $worker->getMaximumRetryCount();
	if ($retry_count === null) {
	$max_retries = phutil_tag('em', array(), pht('Retries Forever'));
	$retry_count = INF;
	} else {
	$max_retries = $retry_count;
	}

	$view->addProperty(
	pht('Maximum Retries'),
	$max_retries);

	$projection = clone $task;
	$projection->makeEphemeral();

	$next = array();
	for ($ii = $task->getFailureCount(); $ii < $retry_count; $ii++) {
	$projection->setFailureCount($ii);
	$next[] = $worker->getWaitBeforeRetry($projection);
	if (count($next) > 10) {
	break;
	}
	}

	if ($next) {
	$cumulative = 0;
	foreach ($next as $key => $duration) {
	if ($duration === null) {
	$duration = 60;
	}
	$cumulative += $duration;
	$next[$key] = phutil_format_relative_time($cumulative);
	}
	if ($ii != $retry_count) {
	$next[] = '...';
	}
	$retries_in = implode(', ', $next);
	} else {
	$retries_in = pht('No More Retries');
	}

	$view->addProperty(
	pht('Retries After'),
	$retries_in);

	return $view;
	}

	}

File Metadata

Mime Type: text/x-php
Expires: Mon, May 12, 8:48 AM (1 d, 21 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 117555
Default Alt Text: PhabricatorWorkerTaskDetailController.php (6 KB)

PhabricatorWorkerTaskDetailController.phpNo OneTemporaryActions

PhabricatorWorkerTaskDetailController.phpView Options

File Metadata

Event Timeline

PhabricatorWorkerTaskDetailController.php
No OneTemporary
Actions

PhabricatorWorkerTaskDetailController.php
View Options