Something went wrong. Try again.
@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
Something went wrong. Try again.
703 B · 33 lines
PHP
12345678910111213141516171819202122232425262728293031323334<?php
final class PhabricatorTaskmasterDaemonModule extends PhutilDaemonOverseerModule {
public function shouldWakePool(PhutilDaemonPool $pool) { $class = $pool->getPoolDaemonClass();
if ($class != PhabricatorTaskmasterDaemon::class) { return false; }
if ($this->shouldThrottle($class, 1)) { return false; }
$table = new PhabricatorWorkerActiveTask(); $conn = $table->establishConnection('r');
$row = queryfx_one( $conn, 'SELECT id FROM %T WHERE leaseOwner IS NULL OR leaseExpires <= %d LIMIT 1', $table->getTableName(), PhabricatorTime::getNow()); if (!$row) { return false; }
return true; }
}