Merge pull request #6897 from appwrite/fix-6895-realtime-deletes
Fix realtime deletes
This commit is contained in:
commit
35891503ef
|
@ -512,13 +512,11 @@ class DeletesV1 extends Worker
|
|||
*/
|
||||
protected function deleteRealtimeUsage(string $datetime): void
|
||||
{
|
||||
$this->deleteForProjectIds(function (Document $project) use ($datetime) {
|
||||
$dbForProject = $this->getProjectDB($project);
|
||||
$dbForConsole = $this->getConsoleDB();
|
||||
// Delete Dead Realtime Logs
|
||||
$this->deleteByGroup('realtime', [
|
||||
Query::lessThan('timestamp', $datetime)
|
||||
], $dbForProject);
|
||||
});
|
||||
], $dbForConsole);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
Loading…
Reference in a new issue