Method cleanup_stale_locks

ci/util/lock_database.py:360–390

Remove all lock rows where owner PID is dead. Returns: Number of stale lock rows removed

(self)

            conn.close()

    def cleanup_stale_locks(self) -> int:
        """Remove all lock rows where owner PID is dead.

        Returns:
            Number of stale lock rows removed
        """
        all_locks = self.list_all_locks()
        if not all_locks:
            return 0

        removed_count = 0
        conn = self._get_connection()
        try:
            cursor = conn.cursor()
            for lock in all_locks:
                pid = lock["owner_pid"]
                if not is_process_alive(pid):
                    cursor.execute(
                        "DELETE FROM lock_holders WHERE lock_name = ? AND owner_pid = ?",
                        (lock["lock_name"], pid),
                    )
                    if cursor.rowcount > 0:
                        removed_count += 1
                        logger.info(
                            f"Cleaned stale lock: {lock['lock_name']} (dead PID {pid})"
                        )
            conn.commit()
        finally:
            conn.close()

        return removed_count

    def force_break_all(self) -> int:
        """Unconditionally remove all lock records.