Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

return for stats

Browse Source
This commit is contained in:
fogelito
2026-05-20 11:53:07 +03:00
parent c1aeaf9bb9
commit 2ef2d4d498
1 changed files with 20 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Workers/Deletes.php
+20 -14
View File
@@ -580,6 +580,10 @@ class Deletes extends Action
*/
private function deleteUsageStats(Document $project, callable $getProjectDB, callable $getLogsDB, string $hourlyUsageRetentionDatetime): void
{
if ($project->getId() === 'console') {
return;
}
/** @var Database $dbForProject */
$dbForProject = $getProjectDB($project);
@@ -594,20 +598,18 @@ class Deletes extends Action
Query::orderDesc(),
], $dbForProject);
if ($project->getId() !== 'console') {
/** @var Database $dbForLogs */
$dbForLogs = call_user_func($getLogsDB, $project);
/** @var Database $dbForLogs */
$dbForLogs = call_user_func($getLogsDB, $project);
// Delete Usage stats from logsDB
$this->deleteByGroup('stats', [
Query::select($selects),
Query::equal('period', ['1h']),
Query::lessThan('time', $hourlyUsageRetentionDatetime),
Query::orderDesc('time'),
Query::orderDesc(),
], $dbForLogs);
}
}
// Delete Usage stats from logsDB
$this->deleteByGroup('stats', [
Query::select($selects),
Query::equal('period', ['1h']),
Query::lessThan('time', $hourlyUsageRetentionDatetime),
Query::orderDesc('time'),
Query::orderDesc(),
], $dbForLogs);
}
/**
* @param callable $getProjectDB
@@ -1016,6 +1018,10 @@ class Deletes extends Action
*/
private function deleteExecutionLogs(Document $project, callable $getProjectDB, string $datetime, ?int $executionsRetentionCount = 0): void
{
if($project->getId() === 'console') {
return;
}
/** @var Database $dbForProject */
$dbForProject = $getProjectDB($project);
@@ -1047,7 +1053,7 @@ class Deletes extends Action
?string $resourceInternalId = null,
?string $resourceType = null
): void {
if ($executionsRetentionCount <= 0) {
if ($executionsRetentionCount <= 0 || $project->getId() === 'console') {
return;
}