Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 08:58:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: maintenance logic.

Browse source
This commit is contained in:
Darshan 2026-01-16 16:04:54 +05:30
parent 79e150b7b2
commit b5e9c1786a
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Appwrite/Platform/Workers/Deletes.php
View file

@ -201,12 +201,11 @@ class Deletes extends Action
break;
case DELETE_TYPE_MAINTENANCE:
$this->deleteExpiredTargets($project, $getProjectDB);
$this->deleteExecutionLogs($project, $getProjectDB, $executionRetention);
$this->deleteExecutionLogs($project, $getProjectDB, $executionRetention, $executionsRetentionCount);
$this->deleteAuditLogs($project, $getAudit, $auditRetention);
$this->deleteUsageStats($project, $getProjectDB, $getLogsDB, $hourlyUsageRetentionDatetime);
$this->deleteExpiredSessions($project, $getProjectDB);
$this->deleteExpiredTransactions($project, $getProjectDB);
$this->deleteExecutionsByLimit($project, $getProjectDB, $executionsRetentionCount);
break;
default:
throw new \Exception('No delete operation for type: ' . \strval($type));
@ -714,10 +713,11 @@ class Deletes extends Action
* @param Document $project
* @param callable $getProjectDB
* @param string $datetime
* @param int|null $executionsRetentionCount
* @return void
* @throws Exception|DatabaseException
*/
private function deleteExecutionLogs(Document $project, callable $getProjectDB, string $datetime): void
private function deleteExecutionLogs(Document $project, callable $getProjectDB, string $datetime, ?int $executionsRetentionCount = 0): void
{
/** @var Database $dbForProject */
$dbForProject = $getProjectDB($project);
@ -731,7 +731,7 @@ class Deletes extends Action
], $dbForProject);
/* delete based on custom retention, if any */
$this->deleteExecutionsByLimit($project, $getProjectDB);
$this->deleteExecutionsByLimit($project, $getProjectDB, $executionsRetentionCount);
}
/**