PhabricatorScheduleTaskTriggerAction.php
7cbbd7868f21stable

PhabricatorScheduleTaskTriggerAction.php
View Options

			<?php

			/**
			* Trigger action which queues a task.
			*
			* Most triggers should take this action: triggers need to execute as quickly
			* as possible, and should generally queue tasks instead of doing any real
			* work.
			*
			* In some cases, triggers could execute more quickly by examining the
			* scheduled action time and comparing it to the current time, then exiting
			* early if the trigger is executing too far away from real time (for example,
			* it might not make sense to send a meeting reminder after a meeting already
			* happened).
			*
			* However, in most cases the task needs to have this logic anyway (because
			* there may be another arbitrarily long delay between when this code executes
			* and when the task executes), and the cost of queueing a task is very small,
			* and situations where triggers are executing far away from real time should
			* be rare (major downtime or serious problems with the pipeline).
			*
			* The properties of this action map to the parameters of
			* @{method:PhabricatorWorker::scheduleTask}.
			*/
			final class PhabricatorScheduleTaskTriggerAction
			extends PhabricatorTriggerAction {

			public function validateProperties(array $properties) {
			PhutilTypeSpec::checkMap(
			$properties,
			array(
			'class' => 'string',
			'data' => 'map<string, wild>',
			'options' => 'map<string, wild>',
			));
			}

			public function execute($last_epoch, $this_epoch) {
			PhabricatorWorker::scheduleTask(
			$this->getProperty('class'),
			$this->getProperty('data'),
			$this->getProperty('options'));
			}

			}