7.2. Application Manager API

class radical.entk.AppManager(config_path=None, hostname=None, port=None, username=None, password=None, reattempts=None, resubmit_failed=None, autoterminate=None, write_workflow=None, rts=None, rmq_cleanup=None, rts_config=None, name=None)[source]

An application manager takes the responsibility of setting up the communication infrastructure, instantiates the ResourceManager, TaskManager, WFProcessor objects and all their threads and processes. This is the Master object running in the main process and is designed to recover from errors from all other objects, threads and processes.

Arguments:
config_path:Url to config path to be read for AppManager
hostname:host rabbitmq server is running
port:port at which rabbitmq can be accessed
username:username to log in to RabbitMQ
password:password to log in to RabbitMQ
reattempts:number of attempts to re-invoke any failed EnTK components
resubmit_failed:
 resubmit failed tasks (True/False)
autoterminate:terminate resource reservation upon execution of all tasks of first workflow (True/False)
write_workflow:write workflow and mapping to rts entities to a file (post-termination)
rts:Specify RTS to use. Current options: ‘mock’, ‘radical.pilot’ (default if unspecified)
rmq_cleanup:Cleanup all queues created in RabbitMQ server for current execution (default is True)
rts_config:Configuration for the RTS, accepts {‘sandbox_cleanup’: True/False,’db_cleanup’: True/False} when RTS is RP
name:Name of the Application. It should be unique between executions. (default is randomly assigned)
name

Name for the application manager. Allows the user to setup the name of the application manager, as well as its session ID. This name should be unique between different EnTK executions, otherwise it will produce an error.

Getter:Returns the name of the application manager
Setter:Assigns the name of the application manager
Type:String
outputs
Getter:Return list of filenames that are to be staged out after execution
Setter:Assign a list of names of files that need to be staged from the remote machine
resource_desc
Getter:Returns the resource description
Setter:Assigns a resource description
run()[source]

Purpose: Run the application manager. Once the workflow and resource manager have been assigned. Invoking this method will start the setting up the communication infrastructure, submitting a resource request and then submission of all the tasks.

shared_data
Getter:Return list of filenames that are shared between multiple tasks of the application
Setter:Assign a list of names of files that need to be staged to the remote machine
sid

Get the session ID of the current EnTK execution

Getter:Returns the session ID of the EnTK execution
Type:String
workflow
Getter:Return the last workflow assigned for execution
Setter:Assign a new workflow to be executed
workflows
Getter:Return a list of workflows assigned for execution