angee.integrate.sync_runner

Execution helpers for queued bridge sync jobs.

run_bridge_sync_job

def run_bridge_sync_job(model_label: str,
                        pk: int,
                        timestamp: str | datetime | None = None,
                        *,
                        require_queue_token: bool = False) -> dict[str, Any]

Run one concrete bridge sync job through the shared lock/lifecycle path.