@@ -17,71 +17,71 @@ |
||
17 | 17 | use OCP\TaskProcessing\Task; |
18 | 18 | |
19 | 19 | class TaskProcessingSuccessRate implements ISetupCheck { |
20 | - public const MAX_FAILURE_PERCENTAGE = 0.2; |
|
20 | + public const MAX_FAILURE_PERCENTAGE = 0.2; |
|
21 | 21 | |
22 | - public const MAX_DAYS = 14; |
|
22 | + public const MAX_DAYS = 14; |
|
23 | 23 | |
24 | - public function __construct( |
|
25 | - private IL10N $l10n, |
|
26 | - private IManager $taskProcessingManager, |
|
27 | - private ITimeFactory $timeFactory, |
|
28 | - ) { |
|
29 | - } |
|
24 | + public function __construct( |
|
25 | + private IL10N $l10n, |
|
26 | + private IManager $taskProcessingManager, |
|
27 | + private ITimeFactory $timeFactory, |
|
28 | + ) { |
|
29 | + } |
|
30 | 30 | |
31 | - public function getCategory(): string { |
|
32 | - return 'ai'; |
|
33 | - } |
|
31 | + public function getCategory(): string { |
|
32 | + return 'ai'; |
|
33 | + } |
|
34 | 34 | |
35 | - public function getName(): string { |
|
36 | - return $this->l10n->t('Task Processing pickup speed'); |
|
37 | - } |
|
35 | + public function getName(): string { |
|
36 | + return $this->l10n->t('Task Processing pickup speed'); |
|
37 | + } |
|
38 | 38 | |
39 | - public function run(): SetupResult { |
|
40 | - $taskCount = 0; |
|
41 | - $lastNDays = 0; |
|
42 | - while ($taskCount === 0 && $lastNDays < self::MAX_DAYS) { |
|
43 | - $lastNDays++; |
|
44 | - // userId: '' means no filter, whereas null would mean guest |
|
45 | - $tasks = $this->taskProcessingManager->getTasks(userId: '', scheduleAfter: $this->timeFactory->now()->getTimestamp() - (60 * 60 * 24 * $lastNDays)); |
|
46 | - $taskCount = count($tasks); |
|
47 | - } |
|
48 | - if ($taskCount === 0) { |
|
49 | - return SetupResult::success( |
|
50 | - $this->l10n->n( |
|
51 | - 'No scheduled tasks in the last day.', |
|
52 | - 'No scheduled tasks in the last %n days.', |
|
53 | - $lastNDays |
|
54 | - ) |
|
55 | - ); |
|
56 | - } |
|
57 | - $failedCount = 0; |
|
58 | - foreach ($tasks as $task) { |
|
59 | - if ($task->getEndedAt() === null) { |
|
60 | - continue; // task was not picked up yet |
|
61 | - } |
|
62 | - $status = $task->getStatus(); |
|
63 | - if ($status === Task::STATUS_FAILED) { |
|
64 | - $failedCount++; |
|
65 | - } |
|
66 | - } |
|
39 | + public function run(): SetupResult { |
|
40 | + $taskCount = 0; |
|
41 | + $lastNDays = 0; |
|
42 | + while ($taskCount === 0 && $lastNDays < self::MAX_DAYS) { |
|
43 | + $lastNDays++; |
|
44 | + // userId: '' means no filter, whereas null would mean guest |
|
45 | + $tasks = $this->taskProcessingManager->getTasks(userId: '', scheduleAfter: $this->timeFactory->now()->getTimestamp() - (60 * 60 * 24 * $lastNDays)); |
|
46 | + $taskCount = count($tasks); |
|
47 | + } |
|
48 | + if ($taskCount === 0) { |
|
49 | + return SetupResult::success( |
|
50 | + $this->l10n->n( |
|
51 | + 'No scheduled tasks in the last day.', |
|
52 | + 'No scheduled tasks in the last %n days.', |
|
53 | + $lastNDays |
|
54 | + ) |
|
55 | + ); |
|
56 | + } |
|
57 | + $failedCount = 0; |
|
58 | + foreach ($tasks as $task) { |
|
59 | + if ($task->getEndedAt() === null) { |
|
60 | + continue; // task was not picked up yet |
|
61 | + } |
|
62 | + $status = $task->getStatus(); |
|
63 | + if ($status === Task::STATUS_FAILED) { |
|
64 | + $failedCount++; |
|
65 | + } |
|
66 | + } |
|
67 | 67 | |
68 | - if (($failedCount / $taskCount) < self::MAX_FAILURE_PERCENTAGE) { |
|
69 | - return SetupResult::success( |
|
70 | - $this->l10n->n( |
|
71 | - 'Most tasks were successful in the last day.', |
|
72 | - 'Most tasks were successful in the last %n days.', |
|
73 | - $lastNDays |
|
74 | - ) |
|
75 | - ); |
|
76 | - } else { |
|
77 | - return SetupResult::warning( |
|
78 | - $this->l10n->n( |
|
79 | - 'A lot of tasks failed in the last day. Consider checking the nextcloud log for errors and investigating whether the AI provider apps have been set up correctly.', |
|
80 | - 'A lot of tasks failed in the last %n days. Consider checking the nextcloud log for errors and investigating whether the AI provider apps have been set up correctly.', |
|
81 | - $lastNDays |
|
82 | - ), |
|
83 | - 'https://docs.nextcloud.com/server/latest/admin_manual/ai/insight_and_debugging.html' |
|
84 | - ); |
|
85 | - } |
|
86 | - } |
|
68 | + if (($failedCount / $taskCount) < self::MAX_FAILURE_PERCENTAGE) { |
|
69 | + return SetupResult::success( |
|
70 | + $this->l10n->n( |
|
71 | + 'Most tasks were successful in the last day.', |
|
72 | + 'Most tasks were successful in the last %n days.', |
|
73 | + $lastNDays |
|
74 | + ) |
|
75 | + ); |
|
76 | + } else { |
|
77 | + return SetupResult::warning( |
|
78 | + $this->l10n->n( |
|
79 | + 'A lot of tasks failed in the last day. Consider checking the nextcloud log for errors and investigating whether the AI provider apps have been set up correctly.', |
|
80 | + 'A lot of tasks failed in the last %n days. Consider checking the nextcloud log for errors and investigating whether the AI provider apps have been set up correctly.', |
|
81 | + $lastNDays |
|
82 | + ), |
|
83 | + 'https://docs.nextcloud.com/server/latest/admin_manual/ai/insight_and_debugging.html' |
|
84 | + ); |
|
85 | + } |
|
86 | + } |
|
87 | 87 | } |
@@ -17,59 +17,59 @@ |
||
17 | 17 | use Test\TestCase; |
18 | 18 | |
19 | 19 | class TaskProcessingSuccessRateTest extends TestCase { |
20 | - private IL10N $l10n; |
|
21 | - private ITimeFactory $timeFactory; |
|
22 | - private IManager $taskProcessingManager; |
|
20 | + private IL10N $l10n; |
|
21 | + private ITimeFactory $timeFactory; |
|
22 | + private IManager $taskProcessingManager; |
|
23 | 23 | |
24 | - private TaskProcessingSuccessRate $check; |
|
24 | + private TaskProcessingSuccessRate $check; |
|
25 | 25 | |
26 | - protected function setUp(): void { |
|
27 | - parent::setUp(); |
|
26 | + protected function setUp(): void { |
|
27 | + parent::setUp(); |
|
28 | 28 | |
29 | - $this->l10n = $this->getMockBuilder(IL10N::class)->getMock(); |
|
30 | - $this->timeFactory = $this->getMockBuilder(ITimeFactory::class)->getMock(); |
|
31 | - $this->taskProcessingManager = $this->getMockBuilder(IManager::class)->getMock(); |
|
29 | + $this->l10n = $this->getMockBuilder(IL10N::class)->getMock(); |
|
30 | + $this->timeFactory = $this->getMockBuilder(ITimeFactory::class)->getMock(); |
|
31 | + $this->taskProcessingManager = $this->getMockBuilder(IManager::class)->getMock(); |
|
32 | 32 | |
33 | - $this->check = new TaskProcessingSuccessRate( |
|
34 | - $this->l10n, |
|
35 | - $this->taskProcessingManager, |
|
36 | - $this->timeFactory, |
|
37 | - ); |
|
38 | - } |
|
33 | + $this->check = new TaskProcessingSuccessRate( |
|
34 | + $this->l10n, |
|
35 | + $this->taskProcessingManager, |
|
36 | + $this->timeFactory, |
|
37 | + ); |
|
38 | + } |
|
39 | 39 | |
40 | - public function testPass(): void { |
|
41 | - $tasks = []; |
|
42 | - for ($i = 0; $i < 100; $i++) { |
|
43 | - $task = new Task('test', ['test' => 'test'], 'settings', 'user' . $i); |
|
44 | - $task->setStartedAt(0); |
|
45 | - $task->setEndedAt(1); |
|
46 | - if ($i < 15) { |
|
47 | - $task->setStatus(Task::STATUS_FAILED); // 15% get status FAILED |
|
48 | - } else { |
|
49 | - $task->setStatus(Task::STATUS_SUCCESSFUL); |
|
50 | - } |
|
51 | - $tasks[] = $task; |
|
52 | - } |
|
53 | - $this->taskProcessingManager->method('getTasks')->willReturn($tasks); |
|
40 | + public function testPass(): void { |
|
41 | + $tasks = []; |
|
42 | + for ($i = 0; $i < 100; $i++) { |
|
43 | + $task = new Task('test', ['test' => 'test'], 'settings', 'user' . $i); |
|
44 | + $task->setStartedAt(0); |
|
45 | + $task->setEndedAt(1); |
|
46 | + if ($i < 15) { |
|
47 | + $task->setStatus(Task::STATUS_FAILED); // 15% get status FAILED |
|
48 | + } else { |
|
49 | + $task->setStatus(Task::STATUS_SUCCESSFUL); |
|
50 | + } |
|
51 | + $tasks[] = $task; |
|
52 | + } |
|
53 | + $this->taskProcessingManager->method('getTasks')->willReturn($tasks); |
|
54 | 54 | |
55 | - $this->assertEquals(SetupResult::SUCCESS, $this->check->run()->getSeverity()); |
|
56 | - } |
|
55 | + $this->assertEquals(SetupResult::SUCCESS, $this->check->run()->getSeverity()); |
|
56 | + } |
|
57 | 57 | |
58 | - public function testFail(): void { |
|
59 | - $tasks = []; |
|
60 | - for ($i = 0; $i < 100; $i++) { |
|
61 | - $task = new Task('test', ['test' => 'test'], 'settings', 'user' . $i); |
|
62 | - $task->setStartedAt(0); |
|
63 | - $task->setEndedAt(1); |
|
64 | - if ($i < 30) { |
|
65 | - $task->setStatus(Task::STATUS_FAILED); // 30% get status FAILED |
|
66 | - } else { |
|
67 | - $task->setStatus(Task::STATUS_SUCCESSFUL); |
|
68 | - } |
|
69 | - $tasks[] = $task; |
|
70 | - } |
|
71 | - $this->taskProcessingManager->method('getTasks')->willReturn($tasks); |
|
58 | + public function testFail(): void { |
|
59 | + $tasks = []; |
|
60 | + for ($i = 0; $i < 100; $i++) { |
|
61 | + $task = new Task('test', ['test' => 'test'], 'settings', 'user' . $i); |
|
62 | + $task->setStartedAt(0); |
|
63 | + $task->setEndedAt(1); |
|
64 | + if ($i < 30) { |
|
65 | + $task->setStatus(Task::STATUS_FAILED); // 30% get status FAILED |
|
66 | + } else { |
|
67 | + $task->setStatus(Task::STATUS_SUCCESSFUL); |
|
68 | + } |
|
69 | + $tasks[] = $task; |
|
70 | + } |
|
71 | + $this->taskProcessingManager->method('getTasks')->willReturn($tasks); |
|
72 | 72 | |
73 | - $this->assertEquals(SetupResult::WARNING, $this->check->run()->getSeverity()); |
|
74 | - } |
|
73 | + $this->assertEquals(SetupResult::WARNING, $this->check->run()->getSeverity()); |
|
74 | + } |
|
75 | 75 | } |