diff --git a/db/migrations/20220815113051_UpdateJobQueueTable.php b/db/migrations/20220815113051_UpdateJobQueueTable.php
new file mode 100644
index 00000000..df0e84d3
--- /dev/null
+++ b/db/migrations/20220815113051_UpdateJobQueueTable.php
@@ -0,0 +1,51 @@
+<?php declare(strict_types=1);
+
+use Phinx\Migration\AbstractMigration;
+
+final class UpdateJobQueueTable extends AbstractMigration
+{
+    public function down() : void
+    {
+        $this->execute(
+            <<<SQL
+            DROP TABLE `job_queue`
+            SQL
+        );
+
+        $this->execute(
+            <<<SQL
+            CREATE TABLE `job_queue` (
+                `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,
+                `job` TEXT NOT NULL,
+                `created_at` DATETIME NOT NULL DEFAULT NOW(),
+                PRIMARY KEY (`id`)
+            ) COLLATE="utf8mb4_unicode_ci" ENGINE=InnoDB
+            SQL
+        );
+    }
+
+    public function up() : void
+    {
+        $this->execute(
+            <<<SQL
+            DROP TABLE `job_queue`
+            SQL
+        );
+
+        $this->execute(
+            <<<SQL
+            CREATE TABLE `job_queue` (
+                `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,
+                `job_type` TEXT NOT NULL,
+                `job_status` TEXT NOT NULL,
+                `user_id` INT(10) UNSIGNED DEFAULT NULL,
+                `parameters` TEXT DEFAULT NULL,
+                `updated_at` DATETIME DEFAULT NULL ON UPDATE NOW(),
+                `created_at` DATETIME NOT NULL DEFAULT NOW(),
+                PRIMARY KEY (`id`),
+                FOREIGN KEY (`user_id`) REFERENCES user (`id`)
+            ) COLLATE="utf8mb4_unicode_ci" ENGINE=InnoDB
+            SQL
+        );
+    }
+}
diff --git a/settings/routes.php b/settings/routes.php
index 47df22d3..4322d1b9 100644
--- a/settings/routes.php
+++ b/settings/routes.php
@@ -77,6 +77,11 @@
         '/{username:.+}/most-watched-directors',
         [\Movary\HttpController\MostWatchedDirectorsController::class, 'renderPage']
     );
+    $routeCollector->addRoute(
+        'GET',
+        '/job-queue',
+        [\Movary\HttpController\JobController::class, 'renderQueuePage']
+    );
     $routeCollector->addRoute(
         'GET',
         '/log-movie',
diff --git a/src/Application/Service/Letterboxd/ImportHistory.php b/src/Application/Service/Letterboxd/ImportHistory.php
index ec2284ef..29b56bfc 100644
--- a/src/Application/Service/Letterboxd/ImportHistory.php
+++ b/src/Application/Service/Letterboxd/ImportHistory.php
@@ -8,6 +8,7 @@
 use Movary\Application\Service\Letterboxd\ValueObject\CsvLineHistory;
 use Movary\Application\Service\Tmdb;
 use Movary\Application\Service\Trakt\PlaysPerDateDtoList;
+use Movary\ValueObject\Job;
 use Psr\Log\LoggerInterface;
 
 class ImportHistory
@@ -40,7 +41,7 @@ public function execute(int $userId, string $historyCsvPath, bool $overwriteExis
                 $watchDatesToImport[$movie->getId()] = PlaysPerDateDtoList::create();
             }
 
-            $watchDatesToImport[$movie->getId()]->incrementPlaysForDate($csvLineHistory->getDate    ());
+            $watchDatesToImport[$movie->getId()]->incrementPlaysForDate($csvLineHistory->getDate());
         }
 
         foreach ($watchDates->getRecords() as $watchDate) {
@@ -67,6 +68,16 @@ public function execute(int $userId, string $historyCsvPath, bool $overwriteExis
         unlink($historyCsvPath);
     }
 
+    public function executeJob(Job $job) : void
+    {
+        $userId = $job->getUserId();
+        if ($userId === null) {
+            throw new \RuntimeException('Missing userId');
+        }
+
+        $this->execute($userId, $job->getParameters()['importFile']);
+    }
+
     public function fetchMovieByLetterboxdUri(string $letterboxdUri) : Movie\Entity
     {
         $letterboxdId = basename($letterboxdUri);
diff --git a/src/Application/Service/Letterboxd/ImportRatings.php b/src/Application/Service/Letterboxd/ImportRatings.php
index 1b95575f..b0f38f5f 100644
--- a/src/Application/Service/Letterboxd/ImportRatings.php
+++ b/src/Application/Service/Letterboxd/ImportRatings.php
@@ -8,6 +8,7 @@
 use Movary\Application\Movie;
 use Movary\Application\Service\Letterboxd\ValueObject\CsvLineRating;
 use Movary\Application\SyncLog;
+use Movary\ValueObject\Job;
 use Movary\ValueObject\PersonalRating;
 use Psr\Log\LoggerInterface;
 
@@ -62,6 +63,16 @@ public function execute(int $userId, string $ratingsCsvPath, bool $verbose = fal
         unlink($ratingsCsvPath);
     }
 
+    public function executeJob(Job $job) : void
+    {
+        $userId = $job->getUserId();
+        if ($userId === null) {
+            throw new \RuntimeException('Missing userId');
+        }
+
+        $this->execute($userId, $job->getParameters()['importFile']);
+    }
+
     public function findMovieByLetterboxdUri(string $letterboxdUri) : ?Movie\Entity
     {
         $letterboxdId = basename($letterboxdUri);
diff --git a/src/Application/Service/Trakt/SyncRatings.php b/src/Application/Service/Trakt/SyncRatings.php
index 588c6075..aeacd991 100644
--- a/src/Application/Service/Trakt/SyncRatings.php
+++ b/src/Application/Service/Trakt/SyncRatings.php
@@ -6,6 +6,7 @@
 use Movary\Application;
 use Movary\Application\Service\Trakt\Exception\TraktClientIdNotSet;
 use Movary\Application\Service\Trakt\Exception\TraktUserNameNotSet;
+use Movary\ValueObject\Job;
 use Movary\ValueObject\PersonalRating;
 
 class SyncRatings
@@ -55,4 +56,14 @@ public function execute(int $userId, bool $overwriteExistingData = false) : void
 
         $this->scanLogRepository->insertLogForTraktSync();
     }
+
+    public function executeJob(Job $job) : void
+    {
+        $userId = $job->getUserId();
+        if ($userId === null) {
+            throw new \RuntimeException('Missing userId');
+        }
+
+        $this->execute($userId);
+    }
 }
diff --git a/src/Application/Service/Trakt/SyncWatchedMovies.php b/src/Application/Service/Trakt/SyncWatchedMovies.php
index 79c98ffc..c9087fbf 100644
--- a/src/Application/Service/Trakt/SyncWatchedMovies.php
+++ b/src/Application/Service/Trakt/SyncWatchedMovies.php
@@ -8,6 +8,7 @@
 use Movary\Application\Service\Trakt\Exception\TraktClientIdNotSet;
 use Movary\Application\Service\Trakt\Exception\TraktUserNameNotSet;
 use Movary\ValueObject\Date;
+use Movary\ValueObject\Job;
 use Psr\Log\LoggerInterface;
 
 class SyncWatchedMovies
@@ -67,6 +68,16 @@ public function execute(int $userId, bool $overwriteExistingData = false, bool $
         $this->scanLogRepository->insertLogForTraktSync();
     }
 
+    public function executeJob(Job $job) : void
+    {
+        $userId = $job->getUserId();
+        if ($userId === null) {
+            throw new \RuntimeException('Missing userId');
+        }
+
+        $this->execute($userId);
+    }
+
     private function findOrCreateMovieLocally(Api\Trakt\ValueObject\Movie\Dto $watchedMovie) : Application\Movie\Entity
     {
         $traktId = $watchedMovie->getTraktId();
diff --git a/src/Command/ProcessJobs.php b/src/Command/ProcessJobs.php
index 924c221d..0fa9e7fe 100644
--- a/src/Command/ProcessJobs.php
+++ b/src/Command/ProcessJobs.php
@@ -2,6 +2,8 @@
 
 namespace Movary\Command;
 
+use Movary\ValueObject\JobStatus;
+use Movary\ValueObject\JobType;
 use Movary\Worker;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\Console\Input\InputInterface;
@@ -66,17 +68,26 @@ protected function execute(InputInterface $input, OutputInterface $output) : int
         return Command::SUCCESS;
     }
 
-    private function processJob() : ?string
+    private function processJob() : ?JobType
     {
-        $job = $this->repository->fetchOldestJob();
+        $job = $this->repository->fetchOldestWaitingJob();
 
         if ($job === null) {
             return null;
         }
 
-        $this->workerService->processJob($job);
+        try {
+            $this->workerService->setJobToInProgress($job->getId());
+
+            $this->workerService->processJob($job);
+
+            $this->repository->updateJobStatus($job->getId(), JobStatus::createDone());
+        } catch (\Exception $e) {
+            $this->repository->updateJobStatus($job->getId(), JobStatus::createFailed());
+
+            throw $e;
+        }
 
-        /** @noinspection PhpUnreachableStatementInspection */
         return $job->getType();
     }
 }
diff --git a/src/HttpController/JobController.php b/src/HttpController/JobController.php
index e325c2bf..5de1838b 100644
--- a/src/HttpController/JobController.php
+++ b/src/HttpController/JobController.php
@@ -10,6 +10,7 @@
 use Movary\ValueObject\Http\Response;
 use Movary\ValueObject\Http\StatusCode;
 use Movary\Worker\Service;
+use Twig\Environment;
 
 class JobController
 {
@@ -18,9 +19,27 @@ public function __construct(
         private readonly Service $workerService,
         private readonly ImportHistoryFileValidator $letterboxdImportHistoryFileValidator,
         private readonly ImportRatingsFileValidator $letterboxdImportRatingsFileValidator,
+        private readonly Environment $twig,
     ) {
     }
 
+    public function renderQueuePage() : Response
+    {
+        if ($this->authenticationService->isUserAuthenticated() === false) {
+            return Response::createFoundRedirect('/');
+        }
+
+        $jobs = $this->workerService->fetchJobsForStatusPage($this->authenticationService->getCurrentUserId());
+
+        return Response::create(
+            StatusCode::createOk(),
+            $this->twig->render(
+                'page/job-queue.html.twig',
+                ['jobs' => $jobs]
+            ),
+        );
+    }
+
     public function scheduleLetterboxdHistoryImport(Request $request) : Response
     {
         if ($this->authenticationService->isUserAuthenticated() === false) {
@@ -109,7 +128,7 @@ public function scheduleTraktHistorySync() : Response
             return Response::createFoundRedirect('/');
         }
 
-        $this->workerService->addTraktHistorySyncJob($this->authenticationService->getCurrentUserId());
+        $this->workerService->addTraktImportHistoryJob($this->authenticationService->getCurrentUserId());
 
         $_SESSION['scheduledTraktHistorySync'] = true;
 
@@ -126,7 +145,7 @@ public function scheduleTraktRatingsSync() : Response
             return Response::createFoundRedirect('/');
         }
 
-        $this->workerService->addTraktRatingsSyncJob($this->authenticationService->getCurrentUserId());
+        $this->workerService->addTraktImportRatingsJob($this->authenticationService->getCurrentUserId());
 
         $_SESSION['scheduledTraktRatingsSync'] = true;
 
diff --git a/src/ValueObject/Job.php b/src/ValueObject/Job.php
new file mode 100644
index 00000000..678d6a98
--- /dev/null
+++ b/src/ValueObject/Job.php
@@ -0,0 +1,67 @@
+<?php declare(strict_types=1);
+
+namespace Movary\ValueObject;
+
+use Movary\Util\Json;
+
+class Job
+{
+    private function __construct(
+        private readonly int $id,
+        private readonly JobType $type,
+        private readonly JobStatus $status,
+        private readonly ?int $userId,
+        private readonly array $parameters,
+        private readonly ?DateTime $updatedAt,
+        private readonly DateTime $createdAt,
+    ) {
+    }
+
+    public static function createFromArray(array $data) : self
+    {
+        return new self(
+            $data['id'],
+            JobType::createFromString($data['job_type']),
+            JobStatus::createFromString($data['job_status']),
+            $data['user_id'],
+            $data['parameters'] === null ? [] : Json::decode($data['parameters']),
+            $data['updated_at'] === null ? null : DateTime::createFromString($data['updated_at']),
+            DateTime::createFromString($data['created_at']),
+        );
+    }
+
+    public function getCreatedAt() : DateTime
+    {
+        return $this->createdAt;
+    }
+
+    public function getId() : int
+    {
+        return $this->id;
+    }
+
+    public function getParameters() : array
+    {
+        return $this->parameters;
+    }
+
+    public function getStatus() : JobStatus
+    {
+        return $this->status;
+    }
+
+    public function getType() : JobType
+    {
+        return $this->type;
+    }
+
+    public function getUpdatedAt() : ?DateTime
+    {
+        return $this->updatedAt;
+    }
+
+    public function getUserId() : ?int
+    {
+        return $this->userId;
+    }
+}
diff --git a/src/ValueObject/JobList.php b/src/ValueObject/JobList.php
new file mode 100644
index 00000000..06c48ebf
--- /dev/null
+++ b/src/ValueObject/JobList.php
@@ -0,0 +1,33 @@
+<?php declare(strict_types=1);
+
+namespace Movary\ValueObject;
+
+use Movary\AbstractList;
+
+/**
+ * @method Job[] getIterator()
+ * @psalm-suppress ImplementedReturnTypeMismatch
+ */
+class JobList extends AbstractList
+{
+    public static function create() : self
+    {
+        return new self();
+    }
+
+    public static function createFromArray(array $data) : self
+    {
+        $list = new self();
+
+        foreach ($data as $movie) {
+            $list->add(Job::createFromArray($movie));
+        }
+
+        return $list;
+    }
+
+    private function add(Job $dto) : void
+    {
+        $this->data[] = $dto;
+    }
+}
diff --git a/src/ValueObject/JobStatus.php b/src/ValueObject/JobStatus.php
new file mode 100644
index 00000000..07a85f54
--- /dev/null
+++ b/src/ValueObject/JobStatus.php
@@ -0,0 +1,51 @@
+<?php declare(strict_types=1);
+
+namespace Movary\ValueObject;
+
+class JobStatus
+{
+    private const STATUS_DONE = 'done';
+
+    private const STATUS_FAILED = 'failed';
+
+    private const STATUS_IN_PROGRESS = 'in progress';
+
+    private const STATUS_WAITING = 'waiting';
+
+    private function __construct(private readonly string $status)
+    {
+        if (in_array($this->status, [self::STATUS_DONE, self::STATUS_IN_PROGRESS, self::STATUS_WAITING, self::STATUS_FAILED]) === false) {
+            throw new \RuntimeException('Not supported job status: ' . $this->status);
+        }
+    }
+
+    public static function createDone() : self
+    {
+        return new self(self::STATUS_DONE);
+    }
+
+    public static function createFailed() : self
+    {
+        return new self(self::STATUS_FAILED);
+    }
+
+    public static function createFromString(string $status) : self
+    {
+        return new self($status);
+    }
+
+    public static function createInProgress() : self
+    {
+        return new self(self::STATUS_IN_PROGRESS);
+    }
+
+    public static function createWaiting() : self
+    {
+        return new self(self::STATUS_WAITING);
+    }
+
+    public function __toString() : string
+    {
+        return $this->status;
+    }
+}
diff --git a/src/ValueObject/JobType.php b/src/ValueObject/JobType.php
new file mode 100644
index 00000000..0e2e71e2
--- /dev/null
+++ b/src/ValueObject/JobType.php
@@ -0,0 +1,89 @@
+<?php declare(strict_types=1);
+
+namespace Movary\ValueObject;
+
+class JobType
+{
+    private const TYPE_LETTERBOXD_IMPORT_HISTORY = 'letterboxd_import_history';
+
+    private const TYPE_LETTERBOXD_IMPORT_RATINGS = 'letterboxd_import_ratings';
+
+    private const TYPE_TMDB_SYNC = 'tmdb_sync';
+
+    private const TYPE_TRAKT_IMPORT_HISTORY = 'trakt_import_history';
+
+    private const TYPE_TRAKT_IMPORT_RATINGS = 'trakt_import_ratings';
+
+    private function __construct(private readonly string $type)
+    {
+        if (in_array($this->type, [
+                self::TYPE_LETTERBOXD_IMPORT_HISTORY,
+                self::TYPE_LETTERBOXD_IMPORT_RATINGS,
+                self::TYPE_TMDB_SYNC,
+                self::TYPE_TRAKT_IMPORT_HISTORY,
+                self::TYPE_TRAKT_IMPORT_RATINGS,
+            ]) === false) {
+            throw new \RuntimeException('Not supported job type: ' . $this->type);
+        }
+    }
+
+    public static function createFromString(string $status) : self
+    {
+        return new self($status);
+    }
+
+    public static function createLetterboxdImportHistory() : self
+    {
+        return new self(self::TYPE_LETTERBOXD_IMPORT_HISTORY);
+    }
+
+    public static function createLetterboxdImportRatings() : self
+    {
+        return new self(self::TYPE_LETTERBOXD_IMPORT_RATINGS);
+    }
+
+    public static function createTmdbSync() : self
+    {
+        return new self(self::TYPE_TMDB_SYNC);
+    }
+
+    public static function createTraktImportHistory() : self
+    {
+        return new self(self::TYPE_TRAKT_IMPORT_HISTORY);
+    }
+
+    public static function createTraktImportRatings() : self
+    {
+        return new self(self::TYPE_TRAKT_IMPORT_RATINGS);
+    }
+
+    public function __toString() : string
+    {
+        return $this->type;
+    }
+
+    public function isOfTypeLetterboxdImportHistory() : bool
+    {
+        return $this->type === self::TYPE_LETTERBOXD_IMPORT_HISTORY;
+    }
+
+    public function isOfTypeLetterboxdImportRankings() : bool
+    {
+        return $this->type === self::TYPE_LETTERBOXD_IMPORT_RATINGS;
+    }
+
+    public function isOfTypeTmdbSync() : bool
+    {
+        return $this->type === self::TYPE_TMDB_SYNC;
+    }
+
+    public function isOfTypeTraktImportHistory() : bool
+    {
+        return $this->type === self::TYPE_TRAKT_IMPORT_HISTORY;
+    }
+
+    public function isOfTypeTraktImportRatings() : bool
+    {
+        return $this->type === self::TYPE_TRAKT_IMPORT_RATINGS;
+    }
+}
diff --git a/src/Worker/Job.php b/src/Worker/Job.php
deleted file mode 100644
index 33a0e10e..00000000
--- a/src/Worker/Job.php
+++ /dev/null
@@ -1,108 +0,0 @@
-<?php declare(strict_types=1);
-
-namespace Movary\Worker;
-
-use Ramsey\Uuid\Uuid;
-
-class Job implements \JsonSerializable
-{
-    private const TYPE_LETTERBOXD_IMPORT_HISTORY = 'letterboxd_import_history';
-
-    private const TYPE_LETTERBOXD_IMPORT_RATINGS = 'letterboxd_import_ratings';
-
-    private const TYPE_TMDB_SYNC = 'tmdb_sync';
-
-    private const TYPE_TRAKT_SYNC_HISTORY = 'trakt_sync_history';
-
-    private const TYPE_TRAKT_SYNC_RATINGS = 'trakt_sync_ratings';
-
-    private function __construct(
-        private readonly string $uuid,
-        private readonly string $type,
-        private readonly array $parameters
-    ) {
-    }
-
-    public static function createFromArray(array $data) : self
-    {
-        return new self(
-            $data['uuid'],
-            $data['type'],
-            $data['parameters'],
-        );
-    }
-
-    public static function createFromParameters(string $uuid, string $type, array $parameters) : self
-    {
-        return new self($uuid, $type, $parameters);
-    }
-
-    public static function createLetterboxImportHistory(int $userId, string $importFile) : self
-    {
-        return new self((string)Uuid::uuid4(), self::TYPE_LETTERBOXD_IMPORT_HISTORY, ['userId' => $userId, 'importFile' => $importFile]);
-    }
-
-    public static function createLetterboxImportRatings(int $userId, string $importFile) : self
-    {
-        return new self((string)Uuid::uuid4(), self::TYPE_LETTERBOXD_IMPORT_RATINGS, ['userId' => $userId, 'importFile' => $importFile]);
-    }
-
-    public static function createTmdbSync() : self
-    {
-        return new self((string)Uuid::uuid4(), self::TYPE_TMDB_SYNC, []);
-    }
-
-    public static function createTraktHistorySync(int $userId) : self
-    {
-        return new self((string)Uuid::uuid4(), self::TYPE_TRAKT_SYNC_HISTORY, ['userId' => $userId]);
-    }
-
-    public static function createTraktRatingsSync(int $userId) : self
-    {
-        return new self((string)Uuid::uuid4(), self::TYPE_TRAKT_SYNC_RATINGS, ['userId' => $userId]);
-    }
-
-    public function getParameters() : array
-    {
-        return $this->parameters;
-    }
-
-    public function getType() : string
-    {
-        return $this->type;
-    }
-
-    public function isOfTypeLetterboxdImportHistory() : bool
-    {
-        return $this->type === self::TYPE_LETTERBOXD_IMPORT_HISTORY;
-    }
-
-    public function isOfTypeLetterboxdImportRankings() : bool
-    {
-        return $this->type === self::TYPE_LETTERBOXD_IMPORT_RATINGS;
-    }
-
-    public function isOfTypeTmdbSync() : bool
-    {
-        return $this->type === self::TYPE_TMDB_SYNC;
-    }
-
-    public function isOfTypeTraktSyncHistory() : bool
-    {
-        return $this->type === self::TYPE_TRAKT_SYNC_HISTORY;
-    }
-
-    public function isOfTypeTraktSyncRankings() : bool
-    {
-        return $this->type === self::TYPE_TRAKT_SYNC_RATINGS;
-    }
-
-    public function jsonSerialize() : array
-    {
-        return [
-            'uuid' => $this->uuid,
-            'type' => $this->type,
-            'parameters' => $this->parameters,
-        ];
-    }
-}
diff --git a/src/Worker/Repository.php b/src/Worker/Repository.php
index c3c95c20..07818141 100644
--- a/src/Worker/Repository.php
+++ b/src/Worker/Repository.php
@@ -4,6 +4,10 @@
 
 use Doctrine\DBAL\Connection;
 use Movary\Util\Json;
+use Movary\ValueObject\Job;
+use Movary\ValueObject\JobList;
+use Movary\ValueObject\JobStatus;
+use Movary\ValueObject\JobType;
 
 class Repository
 {
@@ -11,35 +15,39 @@ public function __construct(private readonly Connection $dbConnection)
     {
     }
 
-    public function addJob(Job $job) : void
+    public function addJob(JobType $type, JobStatus $status, ?int $userId = null, ?array $parameters = null) : void
     {
         $this->dbConnection->insert(
             'job_queue',
             [
-                'job' => Json::encode($job),
+                'job_type' => $type,
+                'job_status' => $status,
+                'user_id' => $userId,
+                'parameters' => $parameters !== null ? Json::encode($parameters) : null,
             ]
         );
     }
 
-    public function fetchOldestJob() : ?Job
+    public function fetchJobs(int $userId) : JobList
     {
-        $this->dbConnection->beginTransaction();
+        $data = $this->dbConnection->fetchAllAssociative('SELECT * FROM `job_queue` WHERE user_id = ? OR user_id IS NULL ORDER BY created_at DESC, id DESC LIMIT 20', [$userId]);
 
-        $data = $this->dbConnection->fetchAssociative('SELECT * FROM `job_queue` ORDER BY `created_at` LIMIT 1');
+        return JobList::createFromArray($data);
+    }
+
+    public function fetchOldestWaitingJob() : ?Job
+    {
+        $data = $this->dbConnection->fetchAssociative('SELECT * FROM `job_queue` WHERE job_status = ? ORDER BY `created_at` LIMIT 1', [JobStatus::createWaiting()]);
 
         if ($data === false) {
             return null;
         }
 
-        $this->deleteJob($data['id']);
-
-        $this->dbConnection->commit();
-
-        return Job::createFromArray(Json::decode($data['job']));
+        return Job::createFromArray($data);
     }
 
-    private function deleteJob(int $id) : void
+    public function updateJobStatus(int $id, JobStatus $status) : void
     {
-        $this->dbConnection->delete('job_queue', ['id' => $id]);
+        $this->dbConnection->update('job_queue', ['job_status' => (string)$status], ['id' => $id]);
     }
 }
diff --git a/src/Worker/Service.php b/src/Worker/Service.php
index 9ae3318c..9dfd98e4 100644
--- a/src/Worker/Service.php
+++ b/src/Worker/Service.php
@@ -5,6 +5,10 @@
 use Movary\Application\Service\Letterboxd;
 use Movary\Application\Service\Tmdb\SyncMovies;
 use Movary\Application\Service\Trakt;
+use Movary\Application\User\Api;
+use Movary\ValueObject\Job;
+use Movary\ValueObject\JobStatus;
+use Movary\ValueObject\JobType;
 
 class Service
 {
@@ -15,55 +19,72 @@ public function __construct(
         private readonly Letterboxd\ImportRatings $letterboxdImportRatings,
         private readonly Letterboxd\ImportHistory $letterboxdImportHistory,
         private readonly SyncMovies $tmdbSyncMovies,
+        private readonly Api $userApi,
     ) {
     }
 
     public function addLetterboxdImportHistoryJob(int $userId, string $importFile) : void
     {
-        $job = Job::createLetterboxImportHistory($userId, $importFile);
-
-        $this->repository->addJob($job);
+        $this->repository->addJob(JobType::createLetterboxdImportHistory(), JobStatus::createWaiting(), $userId, ['importFile' => $importFile]);
     }
 
     public function addLetterboxdImportRatingsJob(int $userId, string $importFile) : void
     {
-        $job = Job::createLetterboxImportRatings($userId, $importFile);
-
-        $this->repository->addJob($job);
+        $this->repository->addJob(JobType::createLetterboxdImportRatings(), JobStatus::createWaiting(), $userId, ['importFile' => $importFile]);
     }
 
-    public function addTmdbSyncJob() : void
+    public function addTmdbSyncJob(JobStatus $jobStatus) : void
     {
-        $job = Job::createTmdbSync();
-
-        $this->repository->addJob($job);
+        $this->repository->addJob(JobType::createTmdbSync(), $jobStatus);
     }
 
-    public function addTraktHistorySyncJob(int $userId) : void
+    public function addTraktImportHistoryJob(int $userId) : void
     {
-        $job = Job::createTraktHistorySync($userId);
+        $this->repository->addJob(JobType::createTraktImportHistory(), JobStatus::createWaiting(), $userId);
+    }
 
-        $this->repository->addJob($job);
+    public function addTraktImportRatingsJob(int $userId) : void
+    {
+        $this->repository->addJob(JobType::createTraktImportRatings(), JobStatus::createWaiting(), $userId);
     }
 
-    public function addTraktRatingsSyncJob(int $userId) : void
+    public function fetchJobsForStatusPage(int $userId) : array
     {
-        $job = Job::createTraktRatingsSync($userId);
+        $jobs = $this->repository->fetchJobs($userId);
+
+        $jobsData = [];
+        foreach ($jobs as $job) {
+            $jobUserId = $job->getUserId();
 
-        $this->repository->addJob($job);
+            $userName = $jobUserId === null ? null : $this->userApi->fetchUser($jobUserId)->getName();
+
+            $jobsData[] = [
+                'id' => $job->getId(),
+                'type' => $job->getType(),
+                'status' => $job->getStatus(),
+                'userName' => $userName,
+                'updatedAt' => $job->getUpdatedAt(),
+                'createdAt' => $job->getCreatedAt(),
+            ];
+        }
+
+        return $jobsData;
     }
 
     public function processJob(Job $job) : void
     {
-        $parameters = $job->getParameters();
-
         match (true) {
-            $job->isOfTypeLetterboxdImportRankings() => $this->letterboxdImportRatings->execute($parameters['userId'], $parameters['importFile']),
-            $job->isOfTypeLetterboxdImportHistory() => $this->letterboxdImportHistory->execute($parameters['userId'], $parameters['importFile']),
-            $job->isOfTypeTraktSyncRankings() => $this->traktSyncRatings->execute($parameters['userId']),
-            $job->isOfTypeTraktSyncHistory() => $this->traktSyncWatchedMovies->execute($parameters['userId']),
-            $job->isOfTypeTmdbSync() => $this->tmdbSyncMovies->syncMovies(),
+            $job->getType()->isOfTypeLetterboxdImportRankings() => $this->letterboxdImportRatings->executeJob($job),
+            $job->getType()->isOfTypeLetterboxdImportHistory() => $this->letterboxdImportHistory->executeJob($job),
+            $job->getType()->isOfTypeTraktImportRatings() => $this->traktSyncRatings->executeJob($job),
+            $job->getType()->isOfTypeTraktImportHistory() => $this->traktSyncWatchedMovies->executeJob($job),
+            $job->getType()->isOfTypeTmdbSync() => $this->tmdbSyncMovies->syncMovies(),
             default => throw new \RuntimeException('Job type not supported: ' . $job->getType()),
         };
     }
+
+    public function setJobToInProgress(int $id) : void
+    {
+        $this->repository->updateJobStatus($id, JobStatus::createInProgress());
+    }
 }
diff --git a/templates/component/navbar.html.twig b/templates/component/navbar.html.twig
index 9cf42db3..f6f69bee 100644
--- a/templates/component/navbar.html.twig
+++ b/templates/component/navbar.html.twig
@@ -21,6 +21,7 @@
                 </li>
                 {% if loggedIn == true %}
                     <li><a class="dropdown-item {% if requestUrlPath starts with '/settings/' %}active{% endif %}" href="/settings/account">Settings</a></li>
+                    <li><a class="dropdown-item {% if requestUrlPath starts with '/job-status' %}active{% endif %}" href="/job-queue">Job Queue</a></li>
                     <li><a class="dropdown-item" href="/logout">Logout</a></li>
                 {% else %}
                     <li><a class="dropdown-item" href="/login">Login</a></li>
diff --git a/templates/page/job-queue.html.twig b/templates/page/job-queue.html.twig
new file mode 100644
index 00000000..45c68212
--- /dev/null
+++ b/templates/page/job-queue.html.twig
@@ -0,0 +1,41 @@
+{% extends 'base.html.twig' %}
+
+{% block title %}
+    Settings - Account
+{% endblock %}
+
+{% block body %}
+    <main role="main" class="container">
+        {{ include('component/navbar.html.twig') }}
+
+        <div style="padding-top: 1rem">
+            <p>Last 20 Jobs:</p>
+            <div style="text-align: center;">
+                <table class="table">
+                    <thead>
+                    <tr>
+                        <th scope="col">Id</th>
+                        <th scope="col">User</th>
+                        <th scope="col">Type</th>
+                        <th scope="col">Status</th>
+                        <th scope="col">Updated</th>
+                        <th scope="col">Created</th>
+                    </tr>
+                    </thead>
+                    <tbody>
+                    {% for job in jobs %}
+                        <tr>
+                            <td>{{ job.id }}</td>
+                            <td>{{ job.userName|default('-') }}</td>
+                            <td>{{ job.type }}</td>
+                            <td>{{ job.status }}</td>
+                            <td>{{ job.updatedAt|default('-') }}</td>
+                            <td>{{ job.createdAt }}</td>
+                        </tr>
+                    {% endfor %}
+                    </tbody>
+                </table>
+            </div>
+        </div>
+    </main>
+{% endblock %}