Function load_journal

src/workflow/launch.py:36–42

Load a prior run's journal from disk, or None if absent/unreadable.

(path: str)

def load_journal(path: str) -> Optional[dict]:
    """Load a prior run's journal from disk, or None if absent/unreadable."""
    try:
        return Journal.load(Path(path).read_text(encoding="utf-8"))
    except (OSError, ValueError) as exc:
        logger.debug("could not load workflow journal from %s: %s", path, exc)
        return None


async def run_workflow_task(