Node Director
|
Inject user settings in .natural/config ... More...
Public Member Functions | |
JobNode | create (EventEnvironment ev) throws DirectorException |
given an EventEnvironment create a Workflow (JobNode) doing whatever this ScriptTask is intended for | |
void | setJob (RemoteJob job) |
void | exec () throws DirectorException |
Inject user settings in .natural/config ...
JobNode sfi.director.application.scripttask.InjectUserSettings.create | ( | EventEnvironment | ev | ) | throws DirectorException |
given an EventEnvironment create a Workflow (JobNode) doing whatever this ScriptTask is intended for
DirectorException | class refuses to be responsible for this event |
ev | the environment of the event that lead to calling create() |
Implements sfi.director.application.ScriptTask.
References sfi.director.repository.DBSet.add(), sfi.director.jobs.RemoteJob.commit(), sfi.director.jobs.Job.commit(), sfi.director.retriever.RemoteFile.connectSend(), sfi.director.util.Tools.debug(), sfi.director.repository.DBSet.dump(), sfi.director.repository.DBSet.elements(), sfi.director.retriever.RetrieverManager.getConnection(), sfi.director.util.Options.getOptions(), sfi.director.repository.DBObject.getValue(), sfi.director.repository.DBObject.isMember(), sfi.director.util.Setup.localjobqueue, sfi.director.jobs.JobNode.nextTmpFile(), sfi.director.repository.DBSet.replace(), sfi.director.jobs.RemoteJob.setArgument(), sfi.director.jobs.RemoteJob.setHost(), sfi.director.jobs.RemoteJob.setInputFile(), sfi.director.jobs.JobNode.setJob(), sfi.director.jobs.RemoteJob.setMethod(), and sfi.director.repository.DBSet.transform().
void sfi.director.application.scripttask.InjectUserSettings.exec | ( | ) | throws DirectorException |
Implements sfi.director.executor.GenericConnection.
References sfi.director.system.Files.chgrp(), sfi.director.system.Files.chown(), sfi.director.repository.DBConnection.close(), sfi.director.retriever.RemoteFile.connectRetrieve(), sfi.director.repository.DBSet.elements(), sfi.director.jobs.RemoteJob.getArgument(), sfi.director.retriever.RetrieverManager.getConnection(), sfi.director.repository.DBManager.getConnection(), sfi.director.jobs.RemoteJob.getInputFile(), sfi.director.repository.DBConnection.replace(), sfi.director.repository.DBSet.restore(), sfi.director.system.FileStats.setGroupId(), sfi.director.system.FileStats.setOwnerUid(), and sfi.director.repository.DBConnection.truncate().
void sfi.director.application.scripttask.InjectUserSettings.setJob | ( | RemoteJob | job | ) |
Implements sfi.director.executor.GenericConnection.