64 lines
1.9 KiB
Java
64 lines
1.9 KiB
Java
package org.gcube.dataanalysis.dataminer.poolmanager.service;
|
|
|
|
import static org.gcube.common.authorization.client.Constants.authorizationService;
|
|
|
|
import org.gcube.common.authorization.library.AuthorizationEntry;
|
|
***REMOVED***
|
|
***REMOVED***
|
|
***REMOVED***
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Cluster;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.CheckMethod;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.SVNUpdater;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.ServiceConfiguration;
|
|
|
|
public class StagingJob extends DMPMJob ***REMOVED***
|
|
|
|
|
|
private Algorithm algorithm;
|
|
private Cluster stagingCluster;
|
|
private Cluster rProtoCluster;
|
|
private String rProtoVREName;
|
|
|
|
public StagingJob(
|
|
SVNUpdater svnUpdater,
|
|
Algorithm algorithm,
|
|
Cluster stagingCluster,
|
|
Cluster rProtoCluster,
|
|
String rProtoVREName) ***REMOVED***
|
|
super(svnUpdater);
|
|
this.algorithm = algorithm;
|
|
this.stagingCluster = stagingCluster;
|
|
this.rProtoCluster = rProtoCluster;
|
|
this.rProtoVREName = rProtoVREName;
|
|
***REMOVED***
|
|
|
|
***REMOVED***
|
|
protected void execute() ***REMOVED***
|
|
ServiceConfiguration a = new ServiceConfiguration();
|
|
CheckMethod b = new CheckMethod();
|
|
|
|
try ***REMOVED***
|
|
|
|
int ret = this.executeAnsibleWorker(
|
|
createWorker(this.algorithm, this.stagingCluster, true, "root"));
|
|
|
|
if(ret == 0)***REMOVED***
|
|
|
|
if (b.checkMethod(a.getStagingHost(), SecurityTokenProvider.instance.get()))***REMOVED***
|
|
|
|
this.svnUpdater.updateRPRotoDeps(this.algorithm);
|
|
|
|
this.svnUpdater.updateSVNRProtoAlgorithmList(this.algorithm, this.rProtoVREName, "DataMiner Pool Manager", "Proto");
|
|
|
|
***REMOVED*** int ret2 = this.executeAnsibleWorker(
|
|
***REMOVED*** createWorker(this.algorithm, this.rProtoCluster, false, "gcube"));
|
|
***REMOVED***
|
|
***REMOVED***
|
|
|
|
***REMOVED*** catch (Exception e) ***REMOVED***
|
|
e.printStackTrace();
|
|
***REMOVED***
|
|
***REMOVED***
|
|
|
|
***REMOVED***
|