|
__init__(self,
account=None,
workdir=None,
settings=None,
memory=None,
cores=None,
jobLimit=None,
killGroup=True) |
source code
|
|
|
|
|
|
|
_getScript(self,
script=None,
joinString=' ; ' ) |
source code
|
|
|
|
|
_writeJobFile(self,
jobDir,
jobName,
attrDict={ } ,
append=False) |
source code
|
|
|
|
|
|
|
|
|
download(self,
src,
dst=None,
replace=True,
compress=False,
uncompress=False)
Mirror a file from "ACCOUNT:WORKDIR/SRC" to "DST" |
source code
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
getRemotePath(self,
path,
addAccount=False) |
source code
|
|
|
|
|
|
|
|
|
|
|
run(self,
script,
chdirTo=None,
silent=False)
Immediately run a command. |
source code
|
|
|
scp(self,
par1,
par2,
verbose=' transfer ' )
General scp command, par1 and par2 must be full paths, including
machine name |
source code
|
|
|
submit(self,
script=None,
jobDir=None,
jobName=None,
stdout=None,
stderr=None)
Queue a command. |
source code
|
|
|
upload(self,
src,
dst=None,
replace=True,
compress=False,
uncompress=False)
Mirror a file from "SRC" to "ACCOUNT:WORKDIR/DST" |
source code
|
|
|
waitForJob(self,
job,
pollIntervalSeconds=10) |
source code
|
|
|
waitForJobCount(self,
targetCount=0,
pollIntervalSeconds=60,
verbose=True) |
source code
|
|
|
waitForJobs(self,
jobs,
pollIntervalSeconds=60,
timeout=None,
verbose=True) |
source code
|
|