angee.integrate.sync

Bridge sync context and progress helpers.

BridgeProgressReporter

class BridgeProgressReporter()

Persist generic progress for the bridge currently being synchronized.

report

def report(stage: str,
           *,
           message: str = "",
           details: Mapping[str, Any] | None = None,
           **extra: Any) -> dict[str, Any]

Merge progress under a row lock without clobbering a queued run.

bridge_progress_context

@contextmanager
def bridge_progress_context(bridge: Any) -> Any

Make bridge progress reporting available to nested sync code.

current_bridge_progress

def current_bridge_progress() -> BridgeProgressReporter | None

Return the current bridge progress reporter, if a bridge sync is active.