clore
/
hosting
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

do not touch container param

This commit is contained in:
clore 2025-03-18 19:21:40 +00:00
parent 5af4a5c635
commit 95ea84a9a0
2 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clore_hosting/main.py
View File

@ -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"]:

21
lib/docker_deploy.py
View File

@ -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':