From 2be504ed8af021cce13a472fc117c81fd8880d51 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Matej=20Ba=C4=8Do?= <matejbaco2000@gmail.com>
Date: Thu, 18 Jan 2024 09:13:11 +0000
Subject: [PATCH] fix pool is empty webhook worker

---
 app/worker.php                             | 5 ++++-
 src/Appwrite/Platform/Workers/Webhooks.php | 1 +
 2 files changed, 5 insertions(+), 1 deletion(-)

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 61305fbcb3..4ec5abc6fd 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)) {