X-Git-Url: https://plomlompom.com/repos/%22https:/validator.w3.org/static/gitweb.js?a=blobdiff_plain;f=plomtask%2Fprocesses.py;h=4867227e5f4e492ebeeac33c484039f36afca4fd;hb=3558a14701955de18ae7adbda0e93aaee7710a92;hp=8a5bf64d640ba4cd5d3d0aad7ea5306102d92670;hpb=8310bdb39e4f3cba5ac90be1ec57b3df633f436b;p=plomtask

diff --git a/plomtask/processes.py b/plomtask/processes.py
index 8a5bf64..4867227 100644
--- a/plomtask/processes.py
+++ b/plomtask/processes.py
@@ -3,6 +3,7 @@ from __future__ import annotations
 from sqlite3 import Row
 from datetime import datetime
 from plomtask.db import DatabaseConnection
+from plomtask.misc import HandledException
 
 
 class Process:
@@ -35,15 +36,17 @@ class Process:
         return list(processes.values())
 
     @classmethod
-    def by_id(cls, db_conn: DatabaseConnection,
-              id_: int | None, create: bool = False) -> Process | None:
+    def by_id(cls, db_conn: DatabaseConnection, id_: int | None,
+              create: bool = False) -> Process:
         """Collect all Processes and their connected VersionedAttributes."""
         process = None
         for row in db_conn.exec('SELECT * FROM processes '
                                 'WHERE id = ?', (id_,)):
             process = cls(row[0])
             break
-        if create and not process:
+        if not process:
+            if not create:
+                raise HandledException(f'Process not found of id: {id_}')
             process = Process(id_)
         if process:
             for row in db_conn.exec('SELECT * FROM process_titles '