chore: fmt
This commit is contained in:
parent
2f0f7bf9c7
commit
83ffc41d92
|
@ -52,7 +52,7 @@ class Func extends Event
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets function id for the function event.
|
* Sets function id for the function event.
|
||||||
*
|
*
|
||||||
* @param string $functionId
|
* @param string $functionId
|
||||||
*/
|
*/
|
||||||
public function setFunctionId(string $functionId): self
|
public function setFunctionId(string $functionId): self
|
||||||
|
@ -64,7 +64,7 @@ class Func extends Event
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns set function id for the function event.
|
* Returns set function id for the function event.
|
||||||
*
|
*
|
||||||
* @return string|null
|
* @return string|null
|
||||||
*/
|
*/
|
||||||
public function getFunctionId(): ?string
|
public function getFunctionId(): ?string
|
||||||
|
|
|
@ -8,8 +8,8 @@ use Appwrite\Platform\Tasks\Maintenance;
|
||||||
use Appwrite\Platform\Tasks\Migrate;
|
use Appwrite\Platform\Tasks\Migrate;
|
||||||
use Appwrite\Platform\Tasks\QueueCount;
|
use Appwrite\Platform\Tasks\QueueCount;
|
||||||
use Appwrite\Platform\Tasks\QueueRetry;
|
use Appwrite\Platform\Tasks\QueueRetry;
|
||||||
use Appwrite\Platform\Tasks\ScheduleFunctions;
|
|
||||||
use Appwrite\Platform\Tasks\ScheduleExecutions;
|
use Appwrite\Platform\Tasks\ScheduleExecutions;
|
||||||
|
use Appwrite\Platform\Tasks\ScheduleFunctions;
|
||||||
use Appwrite\Platform\Tasks\ScheduleMessages;
|
use Appwrite\Platform\Tasks\ScheduleMessages;
|
||||||
use Appwrite\Platform\Tasks\SDKs;
|
use Appwrite\Platform\Tasks\SDKs;
|
||||||
use Appwrite\Platform\Tasks\Specs;
|
use Appwrite\Platform\Tasks\Specs;
|
||||||
|
|
|
@ -4,7 +4,6 @@ namespace Appwrite\Platform\Tasks;
|
||||||
|
|
||||||
use Appwrite\Event\Func;
|
use Appwrite\Event\Func;
|
||||||
use Cron\CronExpression;
|
use Cron\CronExpression;
|
||||||
use Utopia\CLI\Console;
|
|
||||||
use Utopia\Database\Database;
|
use Utopia\Database\Database;
|
||||||
use Utopia\Pools\Group;
|
use Utopia\Pools\Group;
|
||||||
|
|
||||||
|
@ -41,9 +40,9 @@ class ScheduleExecutions extends ScheduleBase
|
||||||
\go(function () use ($schedule, $pools, $dbForConsole) {
|
\go(function () use ($schedule, $pools, $dbForConsole) {
|
||||||
$queue = $pools->get('queue')->pop();
|
$queue = $pools->get('queue')->pop();
|
||||||
$connection = $queue->getResource();
|
$connection = $queue->getResource();
|
||||||
|
|
||||||
$queueForFunctions = new Func($connection);
|
$queueForFunctions = new Func($connection);
|
||||||
|
|
||||||
$queueForFunctions
|
$queueForFunctions
|
||||||
->setType('schedule')
|
->setType('schedule')
|
||||||
->setFunctionId($schedule['resource']['functionId'])
|
->setFunctionId($schedule['resource']['functionId'])
|
||||||
|
|
Loading…
Reference in a new issue