add realtime event to functions worker
This commit is contained in:
parent
8922db85e2
commit
373b2dfc13
1 changed files with 9 additions and 0 deletions
|
@ -6,6 +6,7 @@ use Appwrite\Database\Adapter\MySQL as MySQLAdapter;
|
||||||
use Appwrite\Database\Adapter\Redis as RedisAdapter;
|
use Appwrite\Database\Adapter\Redis as RedisAdapter;
|
||||||
use Appwrite\Database\Validator\Authorization;
|
use Appwrite\Database\Validator\Authorization;
|
||||||
use Appwrite\Event\Event;
|
use Appwrite\Event\Event;
|
||||||
|
use Appwrite\Event\Realtime;
|
||||||
use Appwrite\Resque\Worker;
|
use Appwrite\Resque\Worker;
|
||||||
use Cron\CronExpression;
|
use Cron\CronExpression;
|
||||||
use Swoole\Runtime;
|
use Swoole\Runtime;
|
||||||
|
@ -487,6 +488,14 @@ class FunctionsV1 extends Worker
|
||||||
|
|
||||||
$executionUpdate->trigger();
|
$executionUpdate->trigger();
|
||||||
|
|
||||||
|
$realtimeUpdate = new Realtime('', '', []);
|
||||||
|
|
||||||
|
$realtimeUpdate
|
||||||
|
->setEvent('functions.executions.update')
|
||||||
|
->setProject($projectId)
|
||||||
|
->setPayload($execution->getArrayCopy())
|
||||||
|
->trigger();
|
||||||
|
|
||||||
$usage = new Event('v1-usage', 'UsageV1');
|
$usage = new Event('v1-usage', 'UsageV1');
|
||||||
|
|
||||||
$usage
|
$usage
|
||||||
|
|
Loading…
Reference in a new issue