Skip to content
Snippets Groups Projects
Commit 20bac759 authored by Björn Vonheiden's avatar Björn Vonheiden
Browse files

Add calling of evaluation script from the run uc py implementation

parent 00923b70
No related branches found
No related tags found
No related merge requests found
...@@ -2,6 +2,7 @@ import argparse # parse arguments from cli ...@@ -2,6 +2,7 @@ import argparse # parse arguments from cli
import atexit # used to clear resources at exit of program (e.g. ctrl-c) import atexit # used to clear resources at exit of program (e.g. ctrl-c)
from kubernetes import client, config # kubernetes api from kubernetes import client, config # kubernetes api
from kubernetes.stream import stream from kubernetes.stream import stream
import lag_analysis
import logging # logging import logging # logging
from os import path # path utilities from os import path # path utilities
import subprocess # execute bash commands import subprocess # execute bash commands
...@@ -20,6 +21,11 @@ def load_variables(): ...@@ -20,6 +21,11 @@ def load_variables():
global args global args
print('Load CLI variables') print('Load CLI variables')
parser = argparse.ArgumentParser(description='Run use case Programm') parser = argparse.ArgumentParser(description='Run use case Programm')
parser.add_argument('--exp-id', '-id',
dest='exp_id',
default='1',
metavar='EXP_ID',
help='ID of the experiment')
parser.add_argument('--use-case', '-uc', parser.add_argument('--use-case', '-uc',
dest='uc_id', dest='uc_id',
default='1', default='1',
...@@ -285,14 +291,10 @@ def wait_execution(): ...@@ -285,14 +291,10 @@ def wait_execution():
return return
def run_evaluation_script(): def run_evaluation():
"""Runs the evaluation script.""" """Runs the evaluation function"""
# TODO: implement print('Run evaluation function')
# # Run eval script lag_analysis.main(args.exp_id, f'uc{args.uc_id}', args.dim_value, args.instances, args.execution_minutes)
# source ../.venv/bin/activate
# python lag_analysis.py $EXP_ID uc1 $DIM_VALUE $INSTANCES
# $EXECUTION_MINUTES
# deactivate
return return
...@@ -388,7 +390,7 @@ def delete_topics(topics): ...@@ -388,7 +390,7 @@ def delete_topics(topics):
print(resp) print(resp)
print('Wait for topic deletion') print('Wait for topic deletion')
time.sleep(5) time.sleep(2)
resp = stream(coreApi.connect_get_namespaced_pod_exec, resp = stream(coreApi.connect_get_namespaced_pod_exec,
"kafka-client", "kafka-client",
'default', 'default',
...@@ -538,6 +540,9 @@ def main(): ...@@ -538,6 +540,9 @@ def main():
wait_execution() wait_execution()
print('---------------------') print('---------------------')
run_evaluation()
print('---------------------')
# Cluster is resetted with atexit method # Cluster is resetted with atexit method
# reset_cluster(wg, app_svc, app_svc_monitor, app_jmx, app_deploy, topics) # reset_cluster(wg, app_svc, app_svc_monitor, app_jmx, app_deploy, topics)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment