public abstract class AbstractWorkflowDataModel extends Object
Constructor and Description |
---|
AbstractWorkflowDataModel() |
Modifier and Type | Method and Description |
---|---|
void |
addDirectory(String name)
create a user defined directory before all jobs started
|
abstract void |
buildWorkflow()
to be Overridden by the workflow author
Called via reflection in WorkflowDataModelFactory
|
SqwFile |
createFile(String name)
Creates a sqwfile attached to the workflow as a whole for provisioning.
|
String |
getBundle_version() |
Map<String,String> |
getConfigs() |
String |
getDate() |
Collection<String> |
getDirectories() |
Environment |
getEnv() |
Map<String,SqwFile> |
getFiles() |
String |
getMetadata_output_dir() |
String |
getMetadata_output_file_prefix() |
String |
getName() |
Collection<String> |
getParentAccessions() |
String |
getProperty(String key)
get the user defined INI files properties
|
String |
getRandom() |
String |
getSeqware_version() |
Map<String,String> |
getTags()
the key-value from metadata.xml
|
String |
getVersion() |
String |
getWorkflow_accession() |
String |
getWorkflow_directory_name() |
String |
getWorkflow_engine() |
String |
getWorkflow_run_accession() |
Workflow |
getWorkflow() |
String |
getWorkflowBaseDir() |
String |
getWorkflowBundleDir() |
boolean |
hasProperty(String key) |
boolean |
hasPropertyAndNotNull(String key) |
boolean |
isMetadataWriteBack()
need metadata writeback? user can override this setting by using --no-metadata or --metadata from command line
|
static void |
prepare(AbstractWorkflowDataModel model)
Validates and potentially modifies the specified model in preparation for launching.
|
void |
setConfigs(Map<String,String> configs)
set the key-value properties for workflow
|
void |
setDate(String date)
set the pre-defined date variable
|
void |
setMetadataWriteBack(boolean b)
need metadata writeback? user can override this setting by using --no-metadata or --metadata from command line
|
void |
setName(String name)
set the workflow name
|
void |
setRandom(String random)
set the pre-defined random variable
|
void |
setTags(Map<String,String> tags)
set the key-value properties from metadata.xml
|
void |
setupDirectory()
to be Overridden by the workflow author.
|
void |
setupEnvironment()
to be Overridden by the workflow author generally people don't override this.
|
Map<String,SqwFile> |
setupFiles()
to be Overridden by the workflow author the place to specify inputs and outputs to the program also, a user can specify inputs and
outputs on jobs directly in which case they are still provisioned properly with respect to the job (inputs before, outputs after)
when you define inputs/outputs here they are provisioned before all jobs and after all jobs respectively
|
void |
setupWorkflow()
to be Overridden by the workflow author you generally don't call this as the workflow author since it promotes hardcoding this will
typically be filled in by maven Called via reflection in WorkflowDataModelFactory
|
void |
setVersion(String version)
set workflow version
|
void |
setWorkflow_engine(String workflow_engine)
default is pegasus
|
void |
setWorkflowBundleDir(String dir) |
void |
wrapup()
to be Overridden by the workflow author
Called via reflection in WorkflowDataModelFactory
|
public static void prepare(AbstractWorkflowDataModel model)
model
- public void setupDirectory()
public void setupWorkflow()
public void setupEnvironment()
public Map<String,SqwFile> setupFiles()
public abstract void buildWorkflow()
public void wrapup()
public String getDate()
public void setDate(String date)
date
- public String getRandom()
public void setRandom(String random)
random
- public String getWorkflowBundleDir()
public void setWorkflowBundleDir(String dir)
public String getName()
public void setName(String name)
name
- public Workflow getWorkflow()
public boolean isMetadataWriteBack()
public void setMetadataWriteBack(boolean b)
b
- public void setConfigs(Map<String,String> configs)
configs
- public String getVersion()
public void setVersion(String version)
version
- public String getWorkflowBaseDir()
public final void setTags(Map<String,String> tags)
tags
- public Environment getEnv()
public void addDirectory(String name)
name
- : directory namepublic Collection<String> getDirectories()
public SqwFile createFile(String name)
name
- public Collection<String> getParentAccessions()
public String getWorkflow_accession()
public String getWorkflow_run_accession()
public String getMetadata_output_file_prefix()
public String getMetadata_output_dir()
public String getWorkflow_engine()
public void setWorkflow_engine(String workflow_engine)
workflow_engine
- public String getProperty(String key) throws Exception
key
- Exception
public boolean hasProperty(String key)
public boolean hasPropertyAndNotNull(String key)
public String getWorkflow_directory_name()
public String getSeqware_version()
public String getBundle_version()
Copyright © 2015 SeqWare. All rights reserved.