gCubeSystem
/
dataminer-pool-manager
16
0
Fork 0
Code Issues Pull Requests Releases 2 Wiki Activity

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@134331 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Paolo Fabriani 2016-11-17 16:16:35 +00:00
parent 58a8ad19cf
commit 21313f0e53
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/ansiblebridge/AnsibleSerializeHelper.java
View File

@ -36,6 +36,8 @@ public class AnsibleSerializeHelper {
for(String r:playbook.getRoles()) {
out+=" - " + r+"\n";
***REMOVED***
out+=" vars:\n";
out+=" os_package_state: present\n";
out = out.trim();
serialize(out, playbookFile);
***REMOVED***

4
src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/ansiblebridge/template/AlgorithmPackage.java
View File

@ -38,10 +38,10 @@ public class AlgorithmPackage {
public Collection<Role> getRoles(TemplateManager tm) {
Collection<Role> out = new Vector<>();
for(String mode:new String[]{"add", "remove", "update"***REMOVED***) {
String roleName = "algorithm-"+this.getAlgorithm().getName()+("add".equals(mode) ? "" : "-"+mode);
String roleName = "gcube-algorithm-"+this.getAlgorithm().getName()+("add".equals(mode) ? "" : "-"+mode);
try {
***REMOVED*** find template
Role template = tm.getRoleTemplate("algorithm-" + mode);
Role template = tm.getRoleTemplate("gcube-algorithm-" + mode);
***REMOVED***
if(template!=null) {
Map<String, String> dictionary = this.getDictionary(this.getAlgorithm());

4
src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/clients/ISClient.java
View File

@ -22,7 +22,7 @@ public class ISClient {
* @param vreName
* @return
*/
public Collection<Host> listDataminersInVRE(String scope) {
public Collection<Host> listDataminersInVRE() {
boolean remote = false;
@ -34,8 +34,6 @@ public class ISClient {
return out;
***REMOVED*** else {
ScopeProvider.instance.set(scope);
SimpleQuery query = queryFor(ServiceEndpoint.class);
query.addCondition("$resource/Profile/Category/text() eq 'DataAnalysis'")

2
src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/service/DataminerPoolManager.java
View File

@ -110,7 +110,7 @@ public class DataminerPoolManager {
***REMOVED*** create the cluster (dataminers in the vre)
Cluster cluster = new Cluster();
for(Host h:new ISClient().listDataminersInVRE(vre)) {
for(Host h:new ISClient().listDataminersInVRE()) {
cluster.addHost(h);
***REMOVED***