HomePhorge
Diffusion Phorge (HEAD -> master) Code

phorge/src/infrastructure/daemon/workers/action/PhabricatorScheduleTaskTriggerAction.php
e81eff68e581HEAD -> master

Last Change
Raw File

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') + array(
'trigger.last-epoch' => $last_epoch,
'trigger.this-epoch' => $this_epoch,
),
$this->getProperty('options'));
}
}

Owner Packages

  • No Owners