Package | Description |
---|---|
edu.isi.pegasus.planner.code | |
edu.isi.pegasus.planner.code.generator | |
edu.isi.pegasus.planner.code.generator.condor |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<java.io.File> |
CodeGenerator.generateCode(ADag dag)
Generates the code for the concrete workflow in the input format of the
workflow executor being used.
|
void |
CodeGenerator.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
CodeGenerator.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
CodeGenerator.reset()
Resets the Code Generator implementation.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.lang.String> |
Braindump.defaultBrainDumpEntries(ADag workflow)
Returns default braindump entries.
|
java.util.Collection<java.io.File> |
PMC.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
java.util.Collection<java.io.File> |
Stork.generateCode(ADag dag)
Generates the code for the concrete workflow in the input format of the
workflow executor being used.
|
java.util.Collection<java.io.File> |
Braindump.generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
java.util.Collection<java.io.File> |
MonitordNotify.generateCode(ADag dag)
Generates the notifications input file.
|
java.util.Collection<java.io.File> |
DAXReplicaStore.generateCode(ADag dag)
Generates the notifications input file.
|
java.util.Collection<java.io.File> |
PBS.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
java.util.Collection<java.io.File> |
Shell.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
java.util.Collection<java.io.File> |
Stampede.generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
void |
PMC.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
Stork.generateCode(ADag dag,
Job job)
Generates the code for a single job in the Stork format.
|
void |
Braindump.generateCode(ADag dag,
Job job)
Method not implemented.
|
void |
MonitordNotify.generateCode(ADag dag,
Job job)
Not implemented
|
void |
DAXReplicaStore.generateCode(ADag dag,
Job job)
Not implemented
|
void |
PBS.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
Shell.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
Stampede.generateCode(ADag dag,
Job job)
Method not implemented.
|
java.util.Collection<java.io.File> |
Braindump.generateCode(ADag dag,
java.util.Map<java.lang.String,java.lang.String> additionalEntries)
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
protected void |
Stampede.generateEventsForDAXTask(java.io.PrintWriter writer,
ADag workflow,
Job job)
Generates stampede events corresponding to jobs/tasks in the DAX
|
protected void |
Stampede.generateEventsForExecutableJob(java.io.PrintWriter writer,
ADag dag,
Job job)
Generates stampede events corresponding to an executable job
|
protected java.lang.String |
Braindump.getSubmitHostname()
Returns the submit hostname
|
void |
Abstract.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
PMC.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
Stork.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
Braindump.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
MonitordNotify.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
DAXReplicaStore.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
PBS.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
Shell.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
Stampede.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
private void |
Shell.initializeWriteHandle(java.lang.String filename)
It initializes the write handle to the output file.
|
void |
Abstract.reset()
Resets the Code Generator implementation.
|
void |
MonitordNotify.reset()
Not implemented
|
void |
DAXReplicaStore.reset()
Not implemented
|
void |
Stampede.reset() |
protected void |
Abstract.writeOutStampedeEvents(ADag workflow)
Writes out the stampedeEventGenerator events for the workflow.
|
Modifier and Type | Class and Description |
---|---|
class |
CondorStyleException
A specific exception for the Condor Style generators.
|
Modifier and Type | Method and Description |
---|---|
protected void |
CondorGenerator.applyStyle(Job job,
java.io.PrintWriter writer)
Applies a submit file style to the job, according to the fact whether
the job has to be submitted directly to condor or to a remote jobmanager
via CondorG and GRAM.
|
protected void |
CondorGenerator.concreteDagEmpty(java.lang.String filename,
ADag dag)
A callout method that dictates what needs to be done in case the concrete
plan that is generated is empty.
|
java.util.Collection<java.io.File> |
CondorGenerator.generateCode(ADag dag)
Generates the code for the concrete workflow in Condor DAGMAN and CondorG
input format.
|
void |
CondorGenerator.generateCode(ADag dag,
Job job)
Generates the code (condor submit file) for a single job.
|
private java.lang.String |
CondorGenerator.gridstart(java.io.PrintWriter writer,
Job job,
boolean isGlobusJob)
This function creates the stdio handling with and without gridstart.
|
protected void |
CondorGenerator.handleCondorVarForJob(Job job)
It updates/adds the condor variables that are got through the Dax with
the values specified in the properties file, pool config file or adds some
variables internally.
|
void |
CondorGenerator.initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
protected java.io.File |
CondorGenerator.initializeDagFileWriter(java.lang.String filename,
ADag workflow)
Initializes the file handler to the dag file and writes the header to it.
|
protected void |
CondorGenerator.printDagString(java.lang.String str)
Writes a string to the dag file.
|
void |
CondorGenerator.reset()
Resets the Code Generator implementation.
|
protected void |
CondorGenerator.writeDagFileTail(ADag dag)
It writes the relations making up the DAG in the dag file and and closes
the file handle to it.
|
protected void |
CondorGenerator.writeDOTFile(java.lang.String filename,
ADag dag)
Writes out the DOT file in the submit directory.
|
protected void |
CondorGenerator.writeJobMapFile(java.lang.String filename,
ADag dag)
Writes out the job map file in the submit directory.
|