diff --git a/app/workers/deletes.php b/app/workers/deletes.php index f831c1df3f..14f05a06a6 100644 --- a/app/workers/deletes.php +++ b/app/workers/deletes.php @@ -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); - // Delete Dead Realtime Logs - $this->deleteByGroup('realtime', [ - Query::lessThan('timestamp', $datetime) - ], $dbForProject); - }); + $dbForConsole = $this->getConsoleDB(); + // Delete Dead Realtime Logs + $this->deleteByGroup('realtime', [ + Query::lessThan('timestamp', $datetime) + ], $dbForConsole); } /**