From 95ea84a9a068b9aa02d69875f348c12e4bca7458 Mon Sep 17 00:00:00 2001
From: clore <support@clore.ai>
Date: Tue, 18 Mar 2025 19:21:40 +0000
Subject: [PATCH] do not touch container param

---
 clore_hosting/main.py |  2 +-
 lib/docker_deploy.py  | 21 ++++++++++++++++++---
 2 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/clore_hosting/main.py b/clore_hosting/main.py
index f110b9f..b6772e8 100644
--- a/clore_hosting/main.py
+++ b/clore_hosting/main.py
@@ -528,7 +528,7 @@ class CloreClient:
     async def submit_specs(self, current_specs):
         try:
             if type(current_specs) == dict:
-                current_specs["backend_version"]=22
+                current_specs["backend_version"]=23
                 current_specs["update_hw"]=True
                 smallest_pcie_width = 999
                 for gpu in current_specs["gpus"]["nvidia"]:
diff --git a/lib/docker_deploy.py b/lib/docker_deploy.py
index 627828e..20367de 100644
--- a/lib/docker_deploy.py
+++ b/lib/docker_deploy.py
@@ -36,6 +36,7 @@ def deploy(validated_containers, allowed_running_containers=[], can_run_partner_
     needed_running_names = []
     paused_names = []
     all_use_volumes = []
+    allowed_container_prefixes = []
     local_volume_list = docker_interface.list_volumes()
     clore_volume_list = []
     for volume in local_volume_list:
@@ -68,6 +69,9 @@ def deploy(validated_containers, allowed_running_containers=[], can_run_partner_
                     if volume_name[:6] == "clore_" and not volume_name in clore_volume_list:
                         docker_interface.create_volume(volume_name)
                 all_use_volumes += validated_container["mandatory_volumes"]
+            
+            if "allowed_container_prefixes" in validated_container:
+                allowed_container_prefixes += validated_container["allowed_container_prefixes"]
 
             container_options = {
                 'image': validated_container["image"],
@@ -183,11 +187,22 @@ def deploy(validated_containers, allowed_running_containers=[], can_run_partner_
 
     for container in all_containers:
         if type(container.name)==str:
-            if container.status == "running":
+            do_not_touch_container = False
+            for container_prefix in allowed_container_prefixes:
+                try:
+                    if container.name[:len(container_prefix)] == container_prefix:
+                        do_not_touch_container = True
+                except Exception as e:
+                    pass
+
+            if container.status == "running" and not do_not_touch_container:
                 all_running_container_names.append(container.name)
-            else:
+            elif not do_not_touch_container:
                 all_stopped_container_names.append(container.name)
-            if background_job.is_background_job_container_name(container.name) and not background_job.is_enabled():
+
+            if do_not_touch_container:
+                pass
+            elif background_job.is_background_job_container_name(container.name) and not background_job.is_enabled():
                 if container.status == "running":
                     container.stop()
             elif container.name in needed_running_names and container.status != 'running':