+def invoke_docker(bluprint, layer):
+ """Start docker container for given layer
+ """
+ cmd = ("docker run"
+ " -v $HOME/.ssh:/root/.ssh"
+ " -v $HOME/.kube/config:/root/.kube/config"
+ " -v $VALIDATION_HOME/tests/variables.yaml:"
+ "/opt/akraino/validation/tests/variables.yaml"
+ " -v $AKRAINO_HOME/results:/opt/akraino/results"
+ " akraino/validation:{0}-latest"
+ " bin/sh -c"
+ " 'cd /opt/akraino/validation "
+ "&& python bluval/bluval.py -l {0} {1}'").format(layer, bluprint)
+ args = [cmd]
+ try:
+ print('Invoking {}'.format(args))
+ subprocess.call(args, shell=True)
+ except OSError:
+ #print('Error while executing {}'.format(args))
+ raise BluvalError(OSError)
+
+
+def invoke_dockers(yaml_loc, layer, blueprint_name):
+ """Parses yaml file and starts docker container for one/all layers
+ """
+ with open(str(yaml_loc)) as yaml_file:
+ yamldoc = yaml.safe_load(yaml_file)
+ blueprint = yamldoc['blueprint']
+ if layer is None or layer == "all":
+ for each_layer in blueprint['layers']:
+ invoke_docker(blueprint_name, each_layer)
+ else:
+ invoke_docker(blueprint_name, layer)
+
+