CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-10-03 19:53:33 +13:00
Code Issues Projects Releases Wiki Activity

Deleted functions

Browse source 
schedules clean up
This commit is contained in:
shimon 2022-11-16 16:31:49 +02:00
parent dd7bd108cc
commit 99823656f0
2 changed files with 15 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/config/variables.php
View file

@ -923,7 +923,7 @@ return [
], ],
[ [
'name' => '_APP_MAINTENANCE_RETENTION_SCHEDULES', 'name' => '_APP_MAINTENANCE_RETENTION_SCHEDULES',
'description' => 'Deleted functions schedule cleanup interval (in seconds) ', 'description' => 'Schedules deletion interval ( in seconds ) ',
'introduction' => '1.2.0', 'introduction' => '1.2.0',
'default' => '86400', 'default' => '86400',
'required' => false, 'required' => false,

35
app/workers/deletes.php
View file

@ -133,39 +133,32 @@ class DeletesV1 extends Worker
protected function deleteSchedules(string $datetime): void protected function deleteSchedules(string $datetime): void
{ {
$sum = $limit = 50; $this->deleteByGroup(
$offset = 0; 'schedules',
/** @var Document[] $functions */ [
while ($sum >= $limit) {
$schedules = $this->getConsoleDB()->find('schedules', [
Query::equal('region', [App::getEnv('_APP_REGION', 'default')]), Query::equal('region', [App::getEnv('_APP_REGION', 'default')]),
Query::equal('resourceType', ['function']), Query::equal('resourceType', ['function']),
Query::lessThanEqual('resourceUpdatedAt', $datetime), Query::lessThanEqual('resourceUpdatedAt', $datetime),
Query::equal('active', [false]), Query::equal('active', [false]),
Query::limit($limit), ],
Query::offset($offset), $this->getConsoleDB(),
]); function (Document $document) {
Console::info('Querying schedule for function ' . $document->getAttribute('resourceId'));
$sum = \count($schedules); $project = $this->getConsoleDB()->getDocument('projects', $document->getAttribute('projectId'));
$offset = $offset + $limit;
foreach ($schedules as $schedule) {
Console::info('Querying schedule for function ' . $schedule->getAttribute('resourceId'));
$project = $this->getConsoleDB()->getDocument('projects', $schedule->getAttribute('projectId'));
if ($project->isEmpty()) { if ($project->isEmpty()) {
Console::success('Deleting schedule for function ' . $schedule->getAttribute('resourceId')); Console::success('Deleting schedule for function ' . $document->getAttribute('resourceId'));
continue; return;
} }
$function = $this->getProjectDB($project)->getDocument('functions', $schedule->getAttribute('resourceId')); $function = $this->getProjectDB($project)->getDocument('functions', $document->getAttribute('resourceId'));
if ($function->isEmpty()) { if ($function->isEmpty()) {
$this->getConsoleDB()->deleteDocument('schedules', $schedule->getId()); $this->getConsoleDB()->deleteDocument('schedules', $document->getId());
Console::success('Deleting schedule for function ' . $schedule->getAttribute('resourceId')); Console::success('Deleting schedule for function ' . $document->getAttribute('resourceId'));
} }
} }
} );
} }
/** /**