Method break_stale_lock

ci/util/lock_database.py:277–308

Remove rows where owner PID is dead. Args: lock_name: Name identifying the lock Returns: True if any stale locks were removed

(self, lock_name: str)

        return True

    def break_stale_lock(self, lock_name: str) -> bool:
        """Remove rows where owner PID is dead.

        Args:
            lock_name: Name identifying the lock

        Returns:
            True if any stale locks were removed
        """
        holders = self.get_lock_info(lock_name)
        if not holders:
            return False

        removed = False
        conn = self._get_connection()
        try:
            cursor = conn.cursor()
            for holder in holders:
                pid = holder["owner_pid"]
                if not is_process_alive(pid):
                    cursor.execute(
                        "DELETE FROM lock_holders WHERE lock_name = ? AND owner_pid = ?",
                        (lock_name, pid),
                    )
                    if cursor.rowcount > 0:
                        removed = True
                        logger.info(f"Broke stale lock: {lock_name} (dead PID {pid})")
            conn.commit()
        finally:
            conn.close()

        return removed

    def force_break(self, lock_name: str) -> bool:
        """Unconditionally remove all holders for a lock.