Differential D13200 Diff 31965 src/infrastructure/daemon/workers/management/PhabricatorWorkerManagementExecuteWorkflow.php
Changeset View
Changeset View
Standalone View
Standalone View
src/infrastructure/daemon/workers/management/PhabricatorWorkerManagementExecuteWorkflow.php
| Show All 36 Lines | foreach ($tasks as $task) { | ||||
| $task->setLeaseExpires(PhabricatorTime::getNow()); | $task->setLeaseExpires(PhabricatorTime::getNow()); | ||||
| $task->save(); | $task->save(); | ||||
| $task_data = id(new PhabricatorWorkerTaskData())->loadOneWhere( | $task_data = id(new PhabricatorWorkerTaskData())->loadOneWhere( | ||||
| 'id = %d', | 'id = %d', | ||||
| $task->getDataID()); | $task->getDataID()); | ||||
| $task->setData($task_data->getData()); | $task->setData($task_data->getData()); | ||||
| $id = $task->getID(); | $console->writeOut( | ||||
| $class = $task->getTaskClass(); | pht( | ||||
| 'Executing task %d (%s)...', | |||||
| $console->writeOut("Executing task {$id} ({$class})..."); | $task->getID(), | ||||
| $task->getTaskClass())); | |||||
| $task = $task->executeTask(); | $task = $task->executeTask(); | ||||
| $ex = $task->getExecutionException(); | $ex = $task->getExecutionException(); | ||||
| if ($ex) { | if ($ex) { | ||||
| throw $ex; | throw $ex; | ||||
| } | } | ||||
| } | } | ||||
| return 0; | return 0; | ||||
| } | } | ||||
| } | } | ||||