Method upsert

src/task_registry.py:118–121

Insert or replace the entry for ``task.id``.

(self, task: TaskStateBase)

    # -- write paths ------------------------------------------------------

    def upsert(self, task: TaskStateBase) -> None:
        """Insert or replace the entry for ``task.id``."""
        with self._lock:
            self._tasks[task.id] = task

    def remove(self, task_id: str) -> bool:
        """Drop the entry; returns True iff something was removed."""