Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 17 additions & 16 deletions installer/install.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
import json
import requests


BASE_DIR = '/tmp'
DKUBE_PATH = BASE_DIR + '/dkube'
KUBEFLOW_APPNAME = 'my-kubeflow'
Expand Down Expand Up @@ -46,7 +45,7 @@ def cmd_help(cmd):
elif (cmd == "delete"):
pretty_red("SYNTAX: %s %s --pkg <all, dkube, dkube-ui, kubeflow>"% (sys.argv[0], cmd))
elif (cmd == "operator"):
pretty_red("SYNTAX: %s %s --add <git_username> --org <organisation> --token <admin-token>"% (sys.argv[0], cmd))
pretty_red("SYNTAX: %s %s --add <git_username> --org <organisation>"% (sys.argv[0], cmd))
sys.exit(1)

def find_master_ip():
Expand All @@ -58,17 +57,17 @@ def find_master_ip():
return ip_addr


def operator_add(user, org, token):
master_ip = find_master_ip()
url = "http://%s:32222/GPUaaS/operator/super"%master_ip
job = {'username': user, 'organization': org, 'token':token}
data = json.dumps(job)
headers = {'Content-Type': 'application/json'}
result = requests.post(url, data=data, headers=headers)
print("status:",result.status_code)
if (result.status_code != 200):
pretty_red("Operator add Failed")
sys.exit(1)
def operator_add(user, org):
master_ip = find_master_ip()
url = "http://%s:32222/GPUaaS/operator/super"%master_ip
job = {'username': user, 'organization': org}
data = json.dumps(job)
headers = {'Content-Type': 'application/json'}
result = requests.post(url, data=data, headers=headers)
print("status:",result.status_code)
if (result.status_code != 200):
pretty_red("Operator add Failed")
sys.exit(1)

def operator_delete(user, org):
pretty_red("This Feature is not available for now !!! please check the installation document")
Expand Down Expand Up @@ -468,6 +467,9 @@ def dkube_delete():
sys.exit(1)

time.sleep(2)
if not sp.call("df -h | grep /var/dkube/spinner > /dev/null",shell=True, executable='/bin/bash'):
sp.call("umount /var/dkube/spinner",shell=True, executable='/bin/bash')
time.sleep(1)
if os.path.isdir('/var/dkube/'):
shutil.rmtree('/var/dkube/')

Expand Down Expand Up @@ -511,12 +513,12 @@ def delete_kubeflow():
pretty_green("Kubeflow deletion is Done")

def handle_operator(args):
if( (not args.add) or (not args.org) or (not args.token)):
if( (not args.add) or (not args.org)):
cmd_help("operator")
elif(args.add):
username = args.add
pretty_green("Adding operator ...")
operator_add(username, args.org, args.token)
operator_add(username, args.org)
pretty_green("Operator addition is Done ...!!!")

def handle_delete(args):
Expand Down Expand Up @@ -795,7 +797,6 @@ def run():
parser.add_argument("--add", help="Username of operator to be added")
#parser.add_argument("--delete", help="Username of operator to be deleted")
parser.add_argument("--org", help="name of the organization for operator")
parser.add_argument("--token", help="personal token for operator")
parser.add_argument("--client_id", help="Client ID for git OAuth app")
parser.add_argument("--client_secret", help="Client Secret for git OAuth app")
parser.add_argument("--docker_username", help="Username for docker hub")
Expand Down
5 changes: 3 additions & 2 deletions ksonnet/monitoring/all.libsonnet
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
{
parts(params):: {
local monitoring = import "dkube/monitoring/monitoring.libsonnet",
local grafana_config = import "dkube/monitoring/grafana_config.libsonnet",
local gpu_monitoring = import "dkube/monitoring/gpu_monitoring.libsonnet",

all:: monitoring.all(params)
all:: grafana_config.all(params) + gpu_monitoring.all(params)
},
}
Loading