angee.integrate.locks
Live task locks for integration bridge jobs.
bridge_lock_key
python
def bridge_lock_key(bridge: Any) -> LockKeyReturn the shared task lock key for one bridge row.
bridge_advisory_lock
python
@contextmanager
def bridge_advisory_lock(bridge: Any) -> Iterator[bool]Try to hold the live sync lock for bridge during a task.
bridge_is_locked
python
def bridge_is_locked(bridge: Any) -> boolReturn whether the live sync lock for bridge is currently held.