Update zluda-default.py

comfy/customzluda/zluda-default.py

@@ -32,39 +32,213 @@ def parse_requirements_file(requirements_path):
             for line in f:
                 line = line.strip()
                 if line and not line.startswith('#'):
+                    # Handle different version specifiers
                     if '==' in line:
                         pkg, version = line.split('==', 1)
                         requirements[pkg] = version.strip()
                     elif '>=' in line:
                         pkg, version = line.split('>=', 1)
                         requirements[pkg] = version.strip()
+                    elif '~=' in line:  # Compatible release operator
+                        pkg, version = line.split('~=', 1)
+                        requirements[pkg] = version.strip()
+                    # You can add more operators if needed (>, <, <=, !=)
     except FileNotFoundError:
         print(f"  ::  Warning: requirements.txt not found at {requirements_path}")
     return requirements
 
-def ensure_package(package_name, required_version):
+def is_compatible_version(installed_version, required_version, operator='>='):
+    """Check if installed version meets requirement based on operator."""
     try:
-        installed_version = get_package_version(package_name)
-        print(f"Installed version of {package_name}: {installed_version}")
-        
         from packaging import version
-        if version.parse(installed_version) < version.parse(required_version):
+        installed_v = version.parse(installed_version)
-            install_package(package_name, required_version, upgrade=True)
+        required_v = version.parse(required_version)
-            print(f"\n{package_name} outdated. Upgraded to {required_version}.")
+        
-    except Exception:
+        if operator == '>=':
-        install_package(package_name, required_version)
+            return installed_v >= required_v
-        print(f"\n{package_name} was missing. Installed it.")
+        elif operator == '==':
+            return installed_v == required_v
+        elif operator == '~=':
+            # Compatible release: ~=2.0 means >=2.0, <3.0
+            # ~=2.1 means >=2.1, <2.2
+            required_parts = required_v.release
+            if len(required_parts) == 1:
+                # ~=2 means >=2.0, <3.0
+                return (installed_v >= required_v and 
+                        installed_v.release[0] == required_parts[0])
+            else:
+                # ~=2.1 means >=2.1, <2.2
+                return (installed_v >= required_v and 
+                        installed_v.release[:len(required_parts)-1] == required_parts[:-1] and
+                        installed_v.release[len(required_parts)-1] >= required_parts[-1])
+        else:
+            # Default to >= for unknown operators
+            return installed_v >= required_v
+    except Exception as e:
+        print(f"  ::  Version comparison error for {installed_version} vs {required_version}: {e}")
+        return False
 
-def install_package(package_name, version, upgrade=False):
+def uninstall_package(package_name):
+    """Uninstall a package quietly"""
     import subprocess
     import sys
+    try:
+        args = [sys.executable, '-m', 'pip', 'uninstall', package_name, '-y', '--quiet']
+        subprocess.check_call(args)
+        return True
+    except subprocess.CalledProcessError:
+        return False
+
+def check_pydantic_compatibility():
+    """Check if current pydantic packages are compatible, return True if they need reinstalling"""
+    try:
+        # Try to import the problematic class that causes the error
+        from pydantic_settings import TomlConfigSettingsSource
+        # If we get here, the packages are compatible
+        return False
+    except ImportError:
+        # Import failed, packages are incompatible
+        return True
+    except Exception:
+        # Any other error, assume incompatible
+        return True
+
+def handle_pydantic_packages(required_packages):
+    """Special handling for pydantic packages to ensure compatibility"""
+    import subprocess
+    import sys
+    
+    pydantic_packages = ['pydantic', 'pydantic-settings']
+    packages_in_requirements = [pkg for pkg in pydantic_packages if pkg in required_packages]
+    
+    if not packages_in_requirements:
+        return  # No pydantic packages to handle
+    
+    # Check if both packages are available and what versions
+    pydantic_installed = None
+    pydantic_settings_installed = None
+    
+    try:
+        pydantic_installed = get_package_version('pydantic')
+    except:
+        pass
+    
+    try:
+        pydantic_settings_installed = get_package_version('pydantic-settings')
+    except:
+        pass
+    
+    # If both are installed, check compatibility
+    if pydantic_installed and pydantic_settings_installed:
+        print(f"Found pydantic: {pydantic_installed}, pydantic-settings: {pydantic_settings_installed}")
+        
+        # Check if they're compatible by testing the import
+        if not check_pydantic_compatibility():
+            print("  ::  Pydantic packages are compatible, skipping reinstall")
+            return
+        else:
+            print("  ::  Pydantic packages are incompatible, need to reinstall")
+    
+    # If we get here, we need to install/reinstall pydantic packages
+    print("  ::  Setting up pydantic packages for compatibility...")
+    
+    # Uninstall existing versions to avoid conflicts
+    if pydantic_installed:
+        print(f"  ::  Uninstalling existing pydantic {pydantic_installed}")
+        uninstall_package('pydantic')
+    
+    if pydantic_settings_installed:
+        print(f"  ::  Uninstalling existing pydantic-settings {pydantic_settings_installed}")
+        uninstall_package('pydantic-settings')
+    
+    # Install both packages together
+    try:
+        print("  ::  Installing compatible pydantic packages...")
+        combined_args = [sys.executable, '-m', 'pip', 'install', 
+                       'pydantic~=2.0', 
+                       'pydantic-settings~=2.0',
+                       '--quiet', 
+                       '--disable-pip-version-check']
+        
+        subprocess.check_call(combined_args)
+        
+        # Verify installation
+        new_pydantic = get_package_version('pydantic')
+        new_pydantic_settings = get_package_version('pydantic-settings')
+        print(f"  ::  Successfully installed pydantic: {new_pydantic}, pydantic-settings: {new_pydantic_settings}")
+        
+    except subprocess.CalledProcessError as e:
+        print(f"  ::  Failed to install pydantic packages: {e}")
+
+def install_package(package_name, version_spec, upgrade=False):
+    import subprocess
+    import sys
+    
+    # For ~= operator, install with the compatible release syntax
+    if '~=' in version_spec:
+        package_spec = f'{package_name}~={version_spec}'
+    else:
+        package_spec = f'{package_name}=={version_spec}'
+    
     args = [sys.executable, '-m', 'pip', 'install', 
-            f'{package_name}=={version}', 
+            package_spec, 
             '--quiet', 
             '--disable-pip-version-check']
     if upgrade:
         args.append('--upgrade')
-    subprocess.check_call(args)
+    
+    try:
+        subprocess.check_call(args)
+    except subprocess.CalledProcessError as e:
+        print(f"  ::  Failed to install {package_name}: {e}")
+        # Try installing without version constraint as fallback
+        if upgrade and '~=' in package_spec:
+            try:
+                print(f"  ::  Retrying {package_name} installation without version constraint...")
+                fallback_args = [sys.executable, '-m', 'pip', 'install', 
+                               package_name, 
+                               '--upgrade',
+                               '--quiet', 
+                               '--disable-pip-version-check']
+                subprocess.check_call(fallback_args)
+                print(f"  ::  {package_name} installed successfully without version constraint")
+            except subprocess.CalledProcessError as e2:
+                print(f"  ::  Fallback installation also failed: {e2}")
+
+def ensure_package(package_name, required_version, operator='>='):
+    # Skip individual pydantic package handling - they're handled together
+    if package_name in ['pydantic', 'pydantic-settings']:
+        return
+        
+    try:
+        installed_version = get_package_version(package_name)
+        print(f"Installed version of {package_name}: {installed_version}")
+        
+        if not is_compatible_version(installed_version, required_version, operator):
+            install_package(package_name, required_version, upgrade=True)
+            print(f"\n{package_name} outdated. Upgraded to {required_version}.")
+    except Exception as e:
+        print(f"  ::  {package_name} not found or error checking version: {e}")
+        install_package(package_name, required_version)
+        print(f"\n{package_name} was missing. Installed it.")
+
+# Determine operator from requirements.txt
+def get_version_operator(requirements_path, package_name):
+    """Extract the version operator used for a package in requirements.txt"""
+    try:
+        with open(requirements_path, 'r') as f:
+            for line in f:
+                line = line.strip()
+                if line and not line.startswith('#') and line.startswith(package_name):
+                    if '~=' in line:
+                        return '~='
+                    elif '==' in line:
+                        return '=='
+                    elif '>=' in line:
+                        return '>='
+    except FileNotFoundError:
+        pass
+    return '>='  # Default
 
 import os
 requirements_path = os.path.join(os.path.dirname(os.path.dirname(__file__)), 'requirements.txt')
@@ -79,11 +253,21 @@ packages_to_monitor = [
     "pydantic-settings",
 ]
 
-for package_name in packages_to_monitor:
+print("\n  ::  Checking package versions...")
-    if package_name in required_packages:
-        ensure_package(package_name, required_packages[package_name])
-# ------------------- End Version Check -------------------
 
+# Handle pydantic packages first with special logic
+handle_pydantic_packages(required_packages)
+
+# Handle other packages
+for package_name in packages_to_monitor:
+    if package_name in required_packages and package_name not in ['pydantic', 'pydantic-settings']:
+        operator = get_version_operator(requirements_path, package_name)
+        ensure_package(package_name, required_packages[package_name], operator)
+    elif package_name not in ['pydantic', 'pydantic-settings']:
+        print(f"  ::  Warning: {package_name} not found in requirements.txt")
+
+print("  ::  Package version check complete.")
+# ------------------- End Version Check -------------------
 # ------------------- ZLUDA Detection -------------------
 zluda_device_name = torch.cuda.get_device_name() if torch.cuda.is_available() else ""
 is_zluda = zluda_device_name.endswith("[ZLUDA]")