fix(TaskProcessing): Set task status to running when processing via ISynchronousProvider

Signed-off-by: Marcel Klehr <mklehr@gmx.net>

Author: marcelklehr

lib/private/TaskProcessing/Manager.php

@@ -15,6 +15,7 @@
 use OCP\AppFramework\Db\DoesNotExistException;
 use OCP\AppFramework\Db\MultipleObjectsReturnedException;
 use OCP\BackgroundJob\IJobList;
+use OCP\DB\Exception;
 use OCP\EventDispatcher\IEventDispatcher;
 use OCP\Files\AppData\IAppDataFactory;
 use OCP\Files\File;
@@ -870,4 +871,14 @@ public function lockTask(Task $task): bool {
 		$task->setStatus(Task::STATUS_RUNNING);
 		return true;
 	}
+
+	/**
+	 * @throws \JsonException
+	 * @throws Exception
+	 */
+	public function setTaskStatus(Task $task, int $status): void {
+		$task->setStatus($status);
+		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+		$this->taskMapper->update($taskEntity);
+	}
 }

lib/private/TaskProcessing/SynchronousBackgroundJob.php

@@ -18,6 +18,7 @@
 use OCP\TaskProcessing\Exception\ValidationException;
 use OCP\TaskProcessing\IManager;
 use OCP\TaskProcessing\ISynchronousProvider;
+use OCP\TaskProcessing\Task;
 use Psr\Log\LoggerInterface;
 
 class SynchronousBackgroundJob extends QueuedJob {
@@ -61,6 +62,7 @@ protected function run($argument) {
 					return;
 				}
 				try {
+					$this->taskProcessingManager->setTaskStatus($task, Task::STATUS_RUNNING);
 					$output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->taskProcessingManager->setTaskProgress($task->getId(), $progress));
 				} catch (ProcessingException $e) {
 					$this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);

lib/public/TaskProcessing/IManager.php

@@ -172,4 +172,14 @@ public function prepareInputData(Task $task): array;
 	 * @since 30.0.0
 	 */
 	public function lockTask(Task $task): bool;
+
+	/**
+	 * @param Task $task
+	 * @psalm-param Task::STATUS_* $status
+	 * @param int $status
+	 * @throws \JsonException
+	 * @throws Exception
+	 * @since 30.0.0
+	 */
+	public function setTaskStatus(Task $task, int $status): void;
 }