Skip to content

lifecycle

lifecycle

Workspace lifecycle management for Marianne jobs.

Handles archival of workspace files when --fresh is used on self-chaining jobs. This prevents stale validation artifacts from causing false-positive validations on subsequent iterations.

Classes

WorkspaceArchiver 

WorkspaceArchiver(workspace, config)

Archives workspace files to numbered subdirectories.

Used when --fresh flag clears state, to also move non-essential workspace files out of the way so validations (file_exists, command_succeeds) don't pass on stale artifacts from previous iterations.

Source code in src/marianne/workspace/lifecycle.py 
29
30
31
32
33
def __init__(
    self, workspace: Path, config: WorkspaceLifecycleConfig
) -> None:
    self.workspace = workspace
    self.config = config
Functions
archive 
archive()

Archive non-preserved workspace files.

Returns:

Type Description
Path | None

Path to the created archive directory, or None if nothing was archived.
Source code in src/marianne/workspace/lifecycle.py 
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
def archive(self) -> Path | None:
    """Archive non-preserved workspace files.

    Returns:
        Path to the created archive directory, or None if nothing was archived.
    """
    try:
        return self._do_archive()
    except (OSError, ValueError) as e:
        _logger.warning(
            "workspace_archive_failed",
            workspace=str(self.workspace),
            error=str(e),
            exc_info=True,
        )
        return None

Functions