Fix/node check issue (#59)

* sync_info key change

* upgrade helm chart version individual

Author: devalpatel67

application/config/config.py

@@ -25,15 +25,17 @@ class Config:
         "https://raw.githubusercontent.com/akash-network/provider-configs/main/devices/pcie/gpus.json",
     )
     KEYRING_BACKEND = environ.get("KEYRING_BACKEND", "file")
-    AKASH_VERSION = environ.get("AKASH_VERSION", "v0.38.1")
+    AKASH_VERSION = environ.get("AKASH_VERSION", "v1.0.0")
     AKASH_NODE_HELM_CHART_VERSION = environ.get(
-        "AKASH_NODE_HELM_CHART_VERSION", "12.0.3"
+        "AKASH_NODE_HELM_CHART_VERSION", "14.0.0"
     )
     INGRESS_NGINX_VERSION = environ.get("INGRESS_NGINX_VERSION", "4.11.3")
-    PROVIDER_SERVICES_VERSION = environ.get("PROVIDER_SERVICES_VERSION", "v0.6.10")
+    PROVIDER_SERVICES_VERSION = environ.get("PROVIDER_SERVICES_VERSION", "v0.10.1")
     PROVIDER_SERVICES_HELM_CHART_VERSION = environ.get(
-        "PROVIDER_SERVICES_HELM_CHART_VERSION", "11.6.0"
+        "PROVIDER_SERVICES_HELM_CHART_VERSION", "14.0.3"
     )
+    PROVIDER_HOSTNAME_OPERATOR_VERSION = environ.get("PROVIDER_HOSTNAME_OPERATOR_VERSION", "v0.10.0")
+    PROVIDER_INVENTORY_OPERATOR_VERSION = environ.get("PROVIDER_INVENTORY_OPERATOR_VERSION", "v0.10.0")
     PROVIDER_PRICE_SCRIPT_URL = environ.get(
         "PROVIDER_PRICE_SCRIPT_URL",
         "https://raw.githubusercontent.com/akash-network/helm-charts/main/charts/akash-provider/scripts/price_script_generic.sh",

application/service/upgrade_service.py

@@ -3,6 +3,7 @@
 import json
 from typing import Dict, Tuple
 from fastapi import status
+import time
 
 from application.config.config import Config
 from application.exception.application_error import ApplicationError
@@ -325,12 +326,14 @@ async def upgrade_provider(self, ssh_client, task_id: str) -> Dict:
 
             # Upgrade hostname operator
             log.info("Upgrading hostname operator...")
-            akash_hostname_operator_cmd = "helm -n akash-services upgrade akash-hostname-operator akash/akash-hostname-operator" if Config.CHAIN_ID == "akashnet-2" else "helm -n akash-services upgrade akash-hostname-operator akash-dev/akash-hostname-operator --devel"
+            hostname_operator_version = Config.PROVIDER_HOSTNAME_OPERATOR_VERSION.lstrip("v")
+            akash_hostname_operator_cmd = f"helm -n akash-services upgrade akash-hostname-operator akash/akash-hostname-operator --set image.tag={hostname_operator_version}" if Config.CHAIN_ID == "akashnet-2" else f"helm -n akash-services upgrade akash-hostname-operator akash-dev/akash-hostname-operator --set image.tag={hostname_operator_version} --devel"
             run_ssh_command(ssh_client, akash_hostname_operator_cmd, True, task_id=task_id)
 
             # Upgrade inventory operator
             log.info("Upgrading inventory operator...")
-            akash_inventory_operator_cmd = "helm -n akash-services upgrade inventory-operator akash/akash-inventory-operator" if Config.CHAIN_ID == "akashnet-2" else "helm -n akash-services upgrade inventory-operator akash-dev/akash-inventory-operator --devel"
+            inventory_operator_version = Config.PROVIDER_INVENTORY_OPERATOR_VERSION.lstrip("v")
+            akash_inventory_operator_cmd = f"helm -n akash-services upgrade inventory-operator akash/akash-inventory-operator --set image.tag={inventory_operator_version}" if Config.CHAIN_ID == "akashnet-2" else f"helm -n akash-services upgrade inventory-operator akash-dev/akash-inventory-operator --set image.tag={inventory_operator_version} --devel"
             run_ssh_command(ssh_client, akash_inventory_operator_cmd, True, task_id=task_id)
 
             # Update price script
@@ -358,8 +361,11 @@ async def upgrade_provider(self, ssh_client, task_id: str) -> Dict:
             # Verify pod versions
             log.info("Verifying pod versions...")
             verify_cmd = "kubectl -n akash-services get pods -o custom-columns='NAME:.metadata.name,IMAGE:.spec.containers[*].image' | grep -v akash-node"
+            log.info("Waiting for 20 seconds to allow pods to be upgraded...")
+            time.sleep(20) # Wait for the pods to be upgraded
             stdout, _ = run_ssh_command(ssh_client, verify_cmd, True, task_id=task_id)
 
+
             if app_version not in stdout:
                 raise ApplicationError(
                     status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,