X-Git-Url: https://plomlompom.com/repos/foo.html?a=blobdiff_plain;f=plomtask%2Fprocesses.py;h=6249d48445a3488a8f8c4bdd5748b63a5a727ae5;hb=e825a876e82ffbedf0234f4dfb6d6055d9e29241;hp=32eee4d350db5ed78f4501f7016688f5c174c7cb;hpb=951d8ad55c0d54286f9c986257a67dfa9710fcf2;p=plomtask
diff --git a/plomtask/processes.py b/plomtask/processes.py
index 32eee4d..6249d48 100644
--- a/plomtask/processes.py
+++ b/plomtask/processes.py
@@ -52,27 +52,29 @@ class Process(BaseModel, ConditionsRelations):
create: bool = False) -> Process:
"""Collect Process, its VersionedAttributes, and its child IDs."""
process = None
+ from_cache = False
if id_:
- process, _ = super()._by_id(db_conn, id_)
- if not process:
- if not create:
- raise NotFoundException(f'Process not found of id: {id_}')
- process = Process(id_)
- if isinstance(process.id_, int):
- for name in ('title', 'description', 'effort'):
- table = f'process_{name}s'
- for row in db_conn.row_where(table, 'parent', process.id_):
- getattr(process, name).history_from_row(row)
- for row in db_conn.row_where('process_steps', 'owner',
- process.id_):
- step = ProcessStep.from_table_row(db_conn, row)
- process.explicit_steps += [step]
- for name in ('conditions', 'enables', 'disables'):
- table = f'process_{name}'
- for cond_id in db_conn.column_where(table, 'condition',
- 'process', process.id_):
- target = getattr(process, name)
- target += [Condition.by_id(db_conn, cond_id)]
+ process, from_cache = super()._by_id(db_conn, id_)
+ if not from_cache:
+ if not process:
+ if not create:
+ raise NotFoundException(f'Process not found of id: {id_}')
+ process = Process(id_)
+ if isinstance(process.id_, int):
+ for name in ('title', 'description', 'effort'):
+ table = f'process_{name}s'
+ for row in db_conn.row_where(table, 'parent', process.id_):
+ getattr(process, name).history_from_row(row)
+ for row in db_conn.row_where('process_steps', 'owner',
+ process.id_):
+ step = ProcessStep.from_table_row(db_conn, row)
+ process.explicit_steps += [step]
+ for name in ('conditions', 'enables', 'disables'):
+ table = f'process_{name}'
+ for c_id in db_conn.column_where(table, 'condition',
+ 'process', process.id_):
+ target = getattr(process, name)
+ target += [Condition.by_id(db_conn, c_id)]
assert isinstance(process, Process)
return process