fix enqueueResources
This commit is contained in:
parent
0994b0f2de
commit
552c729c5a
3 changed files with 3 additions and 8 deletions
|
@ -24,12 +24,7 @@ abstract class ScheduleBase extends Action
|
||||||
|
|
||||||
abstract public static function getName(): string;
|
abstract public static function getName(): string;
|
||||||
abstract public static function getSupportedResource(): string;
|
abstract public static function getSupportedResource(): string;
|
||||||
|
abstract protected function enqueueResources(Group $pools, Database $dbForConsole, callable $getProjectDB):void;
|
||||||
abstract protected function enqueueResources(
|
|
||||||
Group $pools,
|
|
||||||
Database $dbForConsole,
|
|
||||||
callable $getProjectDB
|
|
||||||
);
|
|
||||||
|
|
||||||
public function __construct()
|
public function __construct()
|
||||||
{
|
{
|
||||||
|
|
|
@ -26,7 +26,7 @@ class ScheduleFunctions extends ScheduleBase
|
||||||
return 'function';
|
return 'function';
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function enqueueResources(Group $pools, Database $dbForConsole): void
|
protected function enqueueResources(Group $pools, Database $dbForConsole, callable $getProjectDB): void
|
||||||
{
|
{
|
||||||
$timerStart = \microtime(true);
|
$timerStart = \microtime(true);
|
||||||
$time = DateTime::now();
|
$time = DateTime::now();
|
||||||
|
|
|
@ -21,7 +21,7 @@ class ScheduleMessages extends ScheduleBase
|
||||||
return 'message';
|
return 'message';
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function enqueueResources(Group $pools, Database $dbForConsole): void
|
protected function enqueueResources(Group $pools, Database $dbForConsole, callable $getProjectDB): void
|
||||||
{
|
{
|
||||||
foreach ($this->schedules as $schedule) {
|
foreach ($this->schedules as $schedule) {
|
||||||
if (!$schedule['active']) {
|
if (!$schedule['active']) {
|
||||||
|
|
Loading…
Reference in a new issue