l10n->t('Task Processing pickup speed'); } public function run(): SetupResult { $taskCount = 0; $lastNDays = 1; while ($taskCount === 0 && $lastNDays < self::MAX_DAYS) { $lastNDays++; // userId: '' means no filter, whereas null would mean guest $tasks = $this->taskProcessingManager->getTasks(userId: '', scheduleAfter: $this->timeFactory->now()->getTimestamp() - (60 * 60 * 24 * $lastNDays)); $taskCount = count($tasks); } if ($taskCount === 0) { return SetupResult::success( $this->l10n->n( 'No scheduled tasks in the last day.', 'No scheduled tasks in the last %n days.', $lastNDays ) ); } $slowCount = 0; foreach ($tasks as $task) { if ($task->getStartedAt() === null) { continue; // task was not picked up yet } if ($task->getScheduledAt() === null) { continue; // task was not scheduled yet -- should not happen, but the API specifies null as return value } $pickupDelay = $task->getScheduledAt() - $task->getStartedAt(); if ($pickupDelay > 60 * 4) { $slowCount++; // task pickup took longer than 4 minutes } } if (($slowCount / $taskCount) < self::MAX_SLOW_PERCENTAGE) { return SetupResult::success( $this->l10n->n( 'The task pickup speed has been ok in the last day.', 'The task pickup speed has been ok in the last %n days.', $lastNDays ) ); } else { return SetupResult::warning( $this->l10n->n( 'The task pickup speed has been slow in the last day. Many tasks took longer than 4 minutes to be picked up. Consider setting up a worker to process tasks in the background.', 'The task pickup speed has been slow in the last %n days. Many tasks took longer than 4 minutes to be picked up. Consider setting up a worker to process tasks in the background.', $lastNDays ), 'https://docs.nextcloud.com/server/latest/admin_manual/ai/overview.html#improve-ai-task-pickup-speed' ); } } }