proactive.model package

Submodules

proactive.model.ProactiveFlowActionType module

class proactive.model.ProactiveFlowActionType.ProactiveFlowActionType

Bases: object

Represents a proactive flow block

blockType (string)

branch()

flow_action_types = {'CONTINUE': 'continue', 'IF': 'if', 'LOOP': 'loop', 'REPLICATE': 'replicate'}

loop()

replicate()

proactive.model.ProactiveFlowBlock module

class proactive.model.ProactiveFlowBlock.ProactiveFlowBlock

Bases: object

Represents a proactive flow block

blockType (string)

end()

flow_block_types = {'END': 'end', 'NONE': 'none', 'START': 'start'}

none()

start()

proactive.model.ProactiveFlowScript module

class proactive.model.ProactiveFlowScript.ProactiveFlowScript(script_language)

Bases: proactive.model.ProactiveScript.ProactiveScript

Represents a proactive flow script

script_language (ProactiveScriptLanguage) implementation (string)

getActionTarget()

getActionTargetContinuation()

getActionTargetElse()

getActionType()

isBranchFlowScript()

isLoopFlowScript()

isReplicateFlowScript()

setActionTarget(target)

setActionTargetContinuation(target)

setActionTargetElse(target)

setActionType(action_type)

proactive.model.ProactiveForkEnv module

class proactive.model.ProactiveForkEnv.ProactiveForkEnv(script_language)

Bases: proactive.model.ProactiveScript.ProactiveScript

Represents a generic proactive fork env script

script_language (ProactiveScriptLanguage) implementation (string) java_home (string)

getJavaHome()

setJavaHome(java_home)

proactive.model.ProactiveJob module

class proactive.model.ProactiveJob.ProactiveJob

Bases: object

Represents a generic proactive job

job_name (string) job_tasks (list) input_folder (string) output_folder (string)

addGenericInformation(key, value)

addTask(task)

addVariable(key, value)

clearGenericInformation()

clearTasks()

clearVariables()

getGenericInformation()

getInputFolder()

getJobName()

getOutputFolder()

getTasks()

getVariables()

hasVariables()

removeGenericInformation(key)

removeTask(task)

removeVariable(key)

setInputFolder(input_folder)

setJobName(job_name)

setOutputFolder(output_folder)

proactive.model.ProactiveScript module

class proactive.model.ProactiveScript.ProactivePostScript(script_language)

Bases: proactive.model.ProactiveScript.ProactiveScript

Represent a post-script for a proactive task

class proactive.model.ProactiveScript.ProactivePreScript(script_language)

Bases: proactive.model.ProactiveScript.ProactiveScript

Represent a pre-script for a proactive task

class proactive.model.ProactiveScript.ProactiveScript(script_language)

Bases: object

Represents a generic proactive script

script_language (ProactiveScriptLanguage) implementation (string)

getImplementation()

getScriptLanguage()

setImplementation(implementation)

setImplementationFromFile(script_file)

setScriptLanguage(script_language)

proactive.model.ProactiveScriptLanguage module

class proactive.model.ProactiveScriptLanguage.ProactiveScriptLanguage

Bases: object

Represents the programming languages supported by Proactive

supported_languages (dict)

docker_compose()

get_supported_languages()

groovy()

is_language_supported(language)

javascript()

jython()

linux_bash()

perl()

powershell()

python()

r()

ruby()

scalaw()

supported_languages = {'DockerCompose': 'docker-compose', 'Groovy': 'groovy', 'Javascript': 'javascript', 'Jython': 'python', 'Linux_Bash': 'bash', 'Perl': 'perl', 'PowerShell': 'powershell', 'Python': 'cpython', 'R': 'R', 'Ruby': 'ruby', 'Scalaw': 'scalaw', 'Windows_Cmd': 'cmd'}

windows_cmd()

proactive.model.ProactiveSelectionScript module

class proactive.model.ProactiveSelectionScript.ProactiveSelectionScript(script_language)

Bases: proactive.model.ProactiveScript.ProactiveScript

Represents a proactive selection script

script_language (ProactiveScriptLanguage) implementation (string) is_dynamic (boolean

isDynamic()

setIsDynamic(is_dynamic)

proactive.model.ProactiveTask module

class proactive.model.ProactiveTask.ProactivePythonTask

Bases: proactive.model.ProactiveTask.ProactiveTask

Represents a proactive python task

setTaskExecutionFromFile(task_file, parameters=[], displayTaskResultOnScheduler=True)

setTaskExecutionFromLambdaFunction(lambda_function)

class proactive.model.ProactiveTask.ProactiveTask(script_language=None)

Bases: object

Represents a generic proactive task

script_language (ProactiveScriptLanguage) fork_environment (ProactiveForkEnv) task_name (string) task_implementation (string) generic_information (map) input_files (list) output_files (list) dependencies (list[ProactiveTask]) pre_script (ProactivePreScript) post_script (ProactivePostScript) flow_script (ProactiveFlowScript) flow_block (ProactiveFlowBlock)

addDependency(task)

addGenericInformation(key, value)

addInputFile(input_file)

addOutputFile(output_file)

addVariable(key, value)

clearDependencies()

clearGenericInformation()

clearInputFiles()

clearOutputFiles()

clearVariables()

getDependencies()

getDescription()

getFlowBlock()

getFlowScript()

getForkEnvironment()

getGenericInformation()

getInputFiles()

getOutputFiles()

getPostScript()

getPreScript()

getScriptLanguage()

getSelectionScript()

getTaskImplementation()

getTaskName()

getVariables()

hasFlowBlock()

hasFlowScript()

hasForkEnvironment()

hasPostScript()

hasPreScript()

hasSelectionScript()

hasVariables()

removeDependency(task)

removeGenericInformation(key)

removeInputFile(input_file)

removeOutputFile(output_file)

removeVariable(key)

setDescription(description)

setFlowBlock(flow_block)

setFlowScript(flow_script)

setForkEnvironment(fork_environment)

setPostScript(post_script)

setPreScript(pre_script)

setScriptLanguage(script_language)

setSelectionScript(selection_script)

setTaskImplementation(task_implementation)

setTaskImplementationFromFile(task_file)

setTaskName(task_name)

Module contents