public class HPCExecutor extends RemoteExecutor
Modifier and Type | Field and Description |
---|---|
static String |
EXECUTOR_NAME |
protected HPCJobInfoDao |
hpcJobInfoDao |
datasetDao, executionDao, fileDescriptorDao, fileStorage, logFileDao, work, workflowStepDao
Constructor and Description |
---|
HPCExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
cancelRemoteJob()
Tries to cancel the job on the remote server.
|
Execution.State |
checkRemoteJob()
Checks the status of the job on the remote server.
|
String |
getExecutorName()
Name of the executor.
|
Execution.State |
getGondolaLogFile() |
String |
getRemoteLog()
Checks the remote server for any log messages.
|
String |
parseJobId(String[] lines) |
Execution.State |
submitRemoteJob(File cwd)
Submit the job to the remote server.
|
protected void |
updateJobScript(ScriptType script,
Map<String,String> fileMap,
List<String> command,
String stagingDir) |
run, startJob, stopJob
flushLog, getExecutionId, getLog, getState, getStepId, isDebug, isExecutorReady, isJobStopped, isStoreLog, print, print, println, println, println, setDebug, setJobInformation, setLog, setState, setStoreLog
public static final String EXECUTOR_NAME
@Inject protected HPCJobInfoDao hpcJobInfoDao
public Execution.State submitRemoteJob(File cwd) throws AbortException, FailedException
RemoteExecutor
submitRemoteJob
in class RemoteExecutor
AbortException
- an abort exception is thrown if the job submission is
aborted.FailedException
- a failed exception is thrown if the job submission fails to
submit properly.protected void updateJobScript(ScriptType script, Map<String,String> fileMap, List<String> command, String stagingDir)
public void cancelRemoteJob()
RemoteExecutor
cancelRemoteJob
in class RemoteExecutor
public Execution.State checkRemoteJob() throws FailedException
RemoteExecutor
checkRemoteJob
in class RemoteExecutor
FailedException
- a failed exception is thrown if the status check fails.public Execution.State getGondolaLogFile()
public String getRemoteLog()
RemoteExecutor
getRemoteLog
in class RemoteExecutor
public String getExecutorName()
Executor
getExecutorName
in class Executor
Copyright © 2020. All rights reserved.