diff --git a/app/init/constants.php b/app/init/constants.php index af5aa7a000..78b8e3a5ae 100644 --- a/app/init/constants.php +++ b/app/init/constants.php @@ -60,6 +60,7 @@ const APP_DATABASE_TIMEOUT_MILLISECONDS_API = 15 * 1000; // 15 seconds const APP_DATABASE_TIMEOUT_MILLISECONDS_WORKER = 300 * 1000; // 5 minutes const APP_DATABASE_TIMEOUT_MILLISECONDS_TASK = 300 * 1000; // 5 minutes const APP_DATABASE_QUERY_MAX_VALUES = 500; +const APP_DATABASE_QUERY_MAX_VALUES_WORKER = 5000; const APP_DATABASE_ENCRYPT_SIZE_MIN = 150; const APP_DATABASE_TXN_TTL_MIN = 60; // 1 minute const APP_DATABASE_TXN_TTL_MAX = 3600; // 1 hour diff --git a/app/worker.php b/app/worker.php index 468408e76d..76f3bb9e8a 100644 --- a/app/worker.php +++ b/app/worker.php @@ -183,7 +183,7 @@ Server::setResource('getLogsDB', function (Group $pools, Cache $cache) { ->setSharedTables(true) ->setNamespace('logsV1') ->setTimeout(APP_DATABASE_TIMEOUT_MILLISECONDS_WORKER) - ->setMaxQueryValues(APP_DATABASE_QUERY_MAX_VALUES); + ->setMaxQueryValues(APP_DATABASE_QUERY_MAX_VALUES_WORKER); // set tenant if ($project !== null && !$project->isEmpty() && $project->getId() !== 'console') { diff --git a/src/Appwrite/Platform/Tasks/ScheduleBase.php b/src/Appwrite/Platform/Tasks/ScheduleBase.php index bcfcffcc98..8ea673703a 100644 --- a/src/Appwrite/Platform/Tasks/ScheduleBase.php +++ b/src/Appwrite/Platform/Tasks/ScheduleBase.php @@ -218,8 +218,7 @@ abstract class ScheduleBase extends Action if (!empty($projectIdsToLoad)) { $projectIdsToLoad = array_values($projectIdsToLoad); - $batchSize = 10_000; - $batchSize = 499; + $batchSize = APP_DATABASE_QUERY_MAX_VALUES_WORKER; $batches = array_chunk($projectIdsToLoad, $batchSize); $projectsLoadStart = microtime(true);