diff --git a/app/worker.php b/app/worker.php index f90717f36e..21d2e09237 100644 --- a/app/worker.php +++ b/app/worker.php @@ -240,7 +240,10 @@ $worker ->inject('error') ->inject('logger') ->inject('log') - ->action(function (Throwable $error, ?Logger $logger, Log $log) use ($queueName) { + ->inject('pools') + ->action(function (Throwable $error, ?Logger $logger, Log $log, Group $pools) use ($queueName) { + $pools->reclaim(); + $version = App::getEnv('_APP_VERSION', 'UNKNOWN'); if ($error instanceof PDOException) { diff --git a/src/Appwrite/Platform/Workers/Webhooks.php b/src/Appwrite/Platform/Workers/Webhooks.php index 459b1946c6..e920d7a13f 100644 --- a/src/Appwrite/Platform/Workers/Webhooks.php +++ b/src/Appwrite/Platform/Workers/Webhooks.php @@ -49,6 +49,7 @@ class Webhooks extends Action */ public function action(Message $message, Database $dbForConsole, Mail $queueForMails, Log $log): void { + $this->errors = []; $payload = $message->getPayload() ?? []; if (empty($payload)) {