Public Member Functions | |
def | retrieve |
def | execute |
def | asyncwait |
def | __init__ |
Private Member Functions | |
def | __finalize |
def | __find_engine |
def | __start_engine |
def | __initialize_helpers |
def | __initialize |
def | __start_hub |
def | __setup_mec |
def | __setup_engine |
def | __clean_furls |
def | __engine_log_root |
def | __mkdir |
def | __mkdir1 |
def | __rmdir |
Static Private Attributes | |
dictionary | __dir |
dictionary | __cert |
dictionary | __furl |
dictionary | __hub |
dictionary | __helpers |
Definition at line 36 of file taskmanager.py.
def taskmanager.taskmanager.__init__ | ( | self, | |
task_path = [''] , |
|||
engines = {'localhost': 1} |
|||
) |
Definition at line 345 of file taskmanager.py.
References taskmanager.taskmanager.__cert, taskmanager.taskmanager.__clean_furls(), taskmanager.taskmanager.__dir, taskmanager.taskmanager.__engine_log_root(), taskmanager.taskmanager.__furl, taskmanager.taskmanager.__hub, taskmanager.taskmanager.__initialize_helpers(), taskmanager.taskmanager.__mkdir(), taskmanager.taskmanager.__start_hub(), and ngc5921_usecase.start.
def taskmanager.taskmanager.__clean_furls | ( | self | ) | [private] |
Definition at line 386 of file taskmanager.py.
References taskmanager.taskmanager.__furl.
Referenced by taskmanager.taskmanager.__finalize(), and taskmanager.taskmanager.__init__().
def taskmanager.taskmanager.__engine_log_root | ( | self | ) | [private] |
Definition at line 394 of file taskmanager.py.
References taskmanager.taskmanager.__dir.
Referenced by taskmanager.taskmanager.__init__().
def taskmanager.taskmanager.__finalize | ( | self | ) | [private] |
Definition at line 137 of file taskmanager.py.
References taskmanager.taskmanager.__clean_furls(), taskmanager.taskmanager.__dir, taskmanager.taskmanager.__hub, and taskmanager.taskmanager.__rmdir().
def taskmanager.taskmanager.__find_engine | ( | self | ) | [private] |
Definition at line 163 of file taskmanager.py.
References taskmanager.taskmanager.__hub, and taskmanager.taskmanager.__start_engine().
Referenced by taskmanager.taskmanager.execute().
def taskmanager.taskmanager.__initialize | ( | self | ) | [private] |
Definition at line 273 of file taskmanager.py.
References taskmanager.taskmanager.__hub, taskmanager.taskmanager.__start_engine(), and asap.asapmath.keys.
Referenced by taskmanager.taskmanager.execute().
def taskmanager.taskmanager.__initialize_helpers | ( | self | ) | [private] |
Definition at line 250 of file taskmanager.py.
References taskmanager.taskmanager.__helpers.
Referenced by taskmanager.taskmanager.__init__().
def taskmanager.taskmanager.__mkdir | ( | self, | |
p | |||
) | [private] |
Definition at line 397 of file taskmanager.py.
References taskmanager.taskmanager.__mkdir1().
Referenced by taskmanager.taskmanager.__init__(), taskmanager.taskmanager.__start_engine(), and taskmanager.taskmanager.__start_hub().
def taskmanager.taskmanager.__mkdir1 | ( | self, | |
p | |||
) | [private] |
Definition at line 406 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__mkdir().
def taskmanager.taskmanager.__rmdir | ( | self, | |
p | |||
) | [private] |
Definition at line 418 of file taskmanager.py.
References taskmanager.taskmanager.__rmdir().
Referenced by taskmanager.taskmanager.__finalize(), and taskmanager.taskmanager.__rmdir().
def taskmanager.taskmanager.__setup_engine | ( | self, | |
engine | |||
) | [private] |
Definition at line 315 of file taskmanager.py.
References taskmanager.taskmanager.__hub.
Referenced by taskmanager.taskmanager.execute().
def taskmanager.taskmanager.__setup_mec | ( | self | ) | [private] |
Definition at line 307 of file taskmanager.py.
References taskmanager.taskmanager.__furl, and taskmanager.taskmanager.__hub.
Referenced by taskmanager.taskmanager.__start_engine(), and taskmanager.taskmanager.execute().
def taskmanager.taskmanager.__start_engine | ( | self, | |
host = 'localhost' , |
|||
num = 1 |
|||
) | [private] |
Definition at line 180 of file taskmanager.py.
References taskmanager.taskmanager.__dir, taskmanager.taskmanager.__furl, taskmanager.taskmanager.__helpers, taskmanager.taskmanager.__hub, taskmanager.taskmanager.__mkdir(), taskmanager.taskmanager.__setup_mec(), and nf_regression.append.
Referenced by taskmanager.taskmanager.__find_engine(), and taskmanager.taskmanager.__initialize().
def taskmanager.taskmanager.__start_hub | ( | self | ) | [private] |
Definition at line 279 of file taskmanager.py.
References taskmanager.taskmanager.__cert, taskmanager.taskmanager.__dir, taskmanager.taskmanager.__furl, taskmanager.taskmanager.__helpers, taskmanager.taskmanager.__hub, and taskmanager.taskmanager.__mkdir().
Referenced by taskmanager.taskmanager.__init__().
def taskmanager.taskmanager.asyncwait | ( | self, | |
handles = [] |
|||
) |
Definition at line 125 of file taskmanager.py.
References taskmanager.taskmanager.retrieve().
def taskmanager.taskmanager.execute | ( | self, | |
taskname, | |||
args, | |||
kwargs | |||
) |
Definition at line 82 of file taskmanager.py.
References taskmanager.taskmanager.__find_engine(), taskmanager.taskmanager.__hub, taskmanager.taskmanager.__initialize(), taskmanager.taskmanager.__setup_engine(), and taskmanager.taskmanager.__setup_mec().
def taskmanager.taskmanager.retrieve | ( | self, | |
receipt | |||
) |
Definition at line 46 of file taskmanager.py.
References taskmanager.taskmanager.__hub, and taskmanager.log_message().
Referenced by taskmanager.taskmanager.asyncwait().
dictionary taskmanager.taskmanager.__cert [static, private] |
Definition at line 39 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__init__(), and taskmanager.taskmanager.__start_hub().
dictionary taskmanager.taskmanager.__dir [static, private] |
Definition at line 38 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__engine_log_root(), taskmanager.taskmanager.__finalize(), taskmanager.taskmanager.__init__(), taskmanager.taskmanager.__start_engine(), and taskmanager.taskmanager.__start_hub().
dictionary taskmanager.taskmanager.__furl [static, private] |
Definition at line 40 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__clean_furls(), taskmanager.taskmanager.__init__(), taskmanager.taskmanager.__setup_mec(), taskmanager.taskmanager.__start_engine(), and taskmanager.taskmanager.__start_hub().
dictionary taskmanager.taskmanager.__helpers [static, private] |
Definition at line 44 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__initialize_helpers(), taskmanager.taskmanager.__start_engine(), and taskmanager.taskmanager.__start_hub().
dictionary taskmanager.taskmanager.__hub [static, private] |
Definition at line 41 of file taskmanager.py.
Referenced by taskmanager.taskmanager.__finalize(), taskmanager.taskmanager.__find_engine(), taskmanager.taskmanager.__init__(), taskmanager.taskmanager.__initialize(), taskmanager.taskmanager.__setup_engine(), taskmanager.taskmanager.__setup_mec(), taskmanager.taskmanager.__start_engine(), taskmanager.taskmanager.__start_hub(), taskmanager.taskmanager.execute(), and taskmanager.taskmanager.retrieve().