mirror of
https://github.com/kevinveenbirkenbach/computer-playbook.git
synced 2026-11-07 19:32:17 +00:00
kevinveenbirkenbachandClaude Fable 5
e2704ffd71
Replace the find_dock_val_by_bkp_entr filter with three role-local lookups that read the live merged applications config: backup_database_containers (backup.database_routine -> service names), backup_image (backup.no_stop_required/disabled -> exact deployed image refs via the image lookup, swarm registry prefix and custom builds included), and backup_hard_restart_projects (backup.project_hard_restart -> compose project names, declared on mailu instead of hardcoded). Pin baudolo to 3.0.0, whose --images-* flags match .Config.Image exactly and whose hard-restart flag is --hard-restart-projects. The restore drill now starts all compose projects in parallel per retry round; the previous serial alphabetical loop deadlocked when a project's migrate service waited on a datastore project that sorted later (mastodon -> postgres), killing the CLI test at the 3600s timeout. Volume restore rsyncs into the mountpoint directly, dropping the rsync helper image remnants from the test env. BREAKING CHANGE: deploys require backup-docker-to-local 3.0.0. Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
44 lines
1.5 KiB
Python
44 lines
1.5 KiB
Python
from __future__ import annotations
|
|
|
|
from collections.abc import Mapping
|
|
from typing import Any
|
|
|
|
from ansible.plugins.loader import lookup_loader
|
|
from ansible.plugins.lookup import LookupBase
|
|
|
|
|
|
class LookupModule(LookupBase):
|
|
"""Container names (``services.<key>.name``) of every service whose
|
|
``backup.database_routine`` is truthy, for baudolo ``--database-containers``.
|
|
|
|
Reads the live merged ``applications`` config; takes no terms.
|
|
"""
|
|
|
|
def run(
|
|
self,
|
|
terms: list[Any] | None,
|
|
variables: dict[str, Any] | None = None,
|
|
**kwargs: Any,
|
|
) -> list[list[str]]:
|
|
vars_ = variables or getattr(self._templar, "available_variables", {}) or {}
|
|
|
|
applications = lookup_loader.get(
|
|
"applications",
|
|
loader=self._loader,
|
|
templar=getattr(self, "_templar", None),
|
|
).run([], variables=vars_)[0]
|
|
|
|
names: set[str] = set()
|
|
if isinstance(applications, Mapping):
|
|
for app in applications.values():
|
|
services = app.get("services") if isinstance(app, Mapping) else None
|
|
if not isinstance(services, Mapping):
|
|
continue
|
|
for svc in services.values():
|
|
backup = svc.get("backup") if isinstance(svc, Mapping) else None
|
|
if isinstance(backup, Mapping) and backup.get("database_routine"):
|
|
name = svc.get("name")
|
|
if name:
|
|
names.add(name)
|
|
return [sorted(names)]
|