diff --git a/generator/src/pkg/service/util.go b/generator/src/pkg/service/util.go index 71f73fd1..3396f3d4 100644 --- a/generator/src/pkg/service/util.go +++ b/generator/src/pkg/service/util.go @@ -26,7 +26,7 @@ const ( VolumePath = "/usr/src/app/config" ImageName = "app" - ImageURL = "ghcr.io/ericssonresearch/cloud-native-app-simulator/app-demo:v3.0.0" + ImageURL = "ghcr.io/ericssonresearch/cloud-native-app-simulator/app-demo:v3.0.1" DefaultExtPort = 80 DefaultPort = 5000 diff --git a/model/restful/utils/task.py b/model/restful/utils/task.py index ac8aa8eb..24dfa82f 100644 --- a/model/restful/utils/task.py +++ b/model/restful/utils/task.py @@ -63,16 +63,16 @@ def run_task(service_name, service_endpoint): response = concatenate_response_simple(response, nw_response) # CPU task - if ("cpu_complexity" in service_endpoint) and len(service_endpoint["cpu_complexity"]["execution_time"]) > 0: + if ("cpu_complexity" in service_endpoint) and service_endpoint["cpu_complexity"]["execution_time"] > 0: cpu_response, _ = execute_cpu_bounded_task(conf=service_endpoint["cpu_complexity"]) response["cpu_task"]["services"].append(source_svc["service"]+"/"+source_svc["endpoint"]) response["cpu_task"]["statuses"].append(cpu_response) # Memory task - if ("memory_complexity" in service_endpoint) and len(service_endpoint["memory_complexity"]["execution_time"]) > 0: - mem_response, _ = execute_memory_bounded_task(conf=service_endpoint["memory_complexity"]) - response["memory_task"]["services"].append(source_svc["service"]+"/"+source_svc["endpoint"]) - response["memory_task"]["statuses"].append(mem_response) + # if ("memory_complexity" in service_endpoint) and len(service_endpoint["memory_complexity"]["execution_time"]) > 0: + # mem_response, _ = execute_memory_bounded_task(conf=service_endpoint["memory_complexity"]) + # response["memory_task"]["services"].append(source_svc["service"]+"/"+source_svc["endpoint"]) + # response["memory_task"]["statuses"].append(mem_response) else: # "parallel" executor = ThreadPoolExecutor(max_workers=3) @@ -84,7 +84,7 @@ def run_task(service_name, service_endpoint): task_futures.append(nw_future) # CPU task - if ("cpu_complexity" in service_endpoint) and len(service_endpoint["cpu_complexity"]["execution_time"]) > 0: + if ("cpu_complexity" in service_endpoint) and service_endpoint["cpu_complexity"]["execution_time"] > 0: cpu_future = executor.submit(execute_cpu_bounded_task, service_endpoint["cpu_complexity"]) task_futures.append(cpu_future)