From bd8d6fdc59e43af2d3e6461e401b2713cf042c26 Mon Sep 17 00:00:00 2001 From: fogelito Date: Mon, 1 Sep 2025 18:35:12 +0300 Subject: [PATCH] Try catch inside --- src/Appwrite/Platform/Workers/Audits.php | 18 ++++++------------ 1 file changed, 6 insertions(+), 12 deletions(-) diff --git a/src/Appwrite/Platform/Workers/Audits.php b/src/Appwrite/Platform/Workers/Audits.php index c99c5eafe4..e8ae2f2168 100644 --- a/src/Appwrite/Platform/Workers/Audits.php +++ b/src/Appwrite/Platform/Workers/Audits.php @@ -134,25 +134,19 @@ class Audits extends Action $logs = $this->logs; $this->logs = []; - try { - foreach ($logs as $projectLogs) { - /** - * @var $projectDocument Document - */ + foreach ($logs as $projectLogs) { + try { $projectDocument = $projectLogs['project']; - - Console::log('Processing Project "'.$projectDocument->getSequence().'" batch with ' . count($projectLogs['logs']) . ' events'); - + Console::log('Processing Project "' . $projectDocument->getSequence() . '" batch with ' . count($projectLogs['logs']) . ' events'); $dbForProject = $getProjectDB($projectDocument); - $audit = new Audit($dbForProject); - $audit->logBatch($projectLogs['logs']); Console::success('Audit logs processed successfully'); + } catch (Throwable $e) { + Console::error('Error processing audit logs for Project "' . $projectDocument->getSequence() . '": ' . $e->getMessage()); } - } catch (Throwable $e) { - Console::error('Error processing audit logs: ' . $e->getMessage()); } + $this->lastTriggeredTime = time(); return new Commit(); }