@recaptime-dev's working patches + fork for Phorge, a community fork of Phabricator. (Upstream dev and stable branches are at upstream/main and upstream/stable respectively.)
hq.recaptime.dev/wiki/Phorge
phorge
phabricator
Worker - supporting running queued tasks in process
Summary: Ref D8930. My "send test" for SMS was failing before this patch, and now it works nicely.
Test Plan: Used new code in D8930 that uses $this->queueTask() to get some work done and it got done in process
Reviewers: epriestley
Reviewed By: epriestley
Subscribers: epriestley, Korvin
Differential Revision: https://secure.phabricator.com/D9018
+4
+4
src/infrastructure/daemon/workers/PhabricatorWorker.php
+4
src/infrastructure/daemon/workers/PhabricatorWorker.php
···
97
97
while (true) {
98
98
try {
99
99
$worker->doWork();
100
+
foreach ($worker->getQueuedTasks() as $queued_task) {
101
+
list($queued_class, $queued_data) = $queued_task;
102
+
self::scheduleTask($queued_class, $queued_data);
103
+
}
100
104
break;
101
105
} catch (PhabricatorWorkerYieldException $ex) {
102
106
phlog(